Uses of Class
net.blakez.bppmq.core.Result
Packages that use Result
Package
Description
-
Uses of Result in net.blakez.bppmq.core
Methods in net.blakez.bppmq.core that return ResultModifier and TypeMethodDescriptionstatic <T> Result<T> Creates a failed Result with a list of errors.static <T> Result<T> Creates a failed Result with a list of errors and potentially a partial value.static <T> Result<T> Creates a failed Result with a single error and potentially a partial value.static <T> Result<T> Creates a failed Result with a single error.static <T> Result<T> Creates a successful Result. -
Uses of Result in net.blakez.bppmq.core.queue
Methods in net.blakez.bppmq.core.queue that return ResultModifier and TypeMethodDescriptionPushPullQueueCore.clearBefore(String topic, long index) Clears messages in the specified topic before the given index.Counts the number of messages available from a specific index onwards.Deletes a message by topic and index.Deletes a message by its UUID.Lists messages for a topic starting from a specific index.Reads a message by its UUID.Retrieves metadata for a given topic.Retrieves metadata information for the specified topic.Pulls a single message from the specified topic at the given index.Pulls a batch of messages from the specified topic starting at the given index.Pulls messages from the specified topic starting from the given index.Pushes a single message to the specified topic.Pushes a batch of messages to the specified topic.Reads a specific message by topic and index.MessageRecordRepository.saveMeta(MetaRecord metaRecord) Saves or updates metadata for a topic.MessageRecordRepository.topics()Retrieves a list of all available topic names.MessageRecordRepository.write(MessageRecord record) Writes a new message record. -
Uses of Result in net.blakez.bppmq.infra.data.queue
Methods in net.blakez.bppmq.infra.data.queue that return ResultModifier and TypeMethodDescriptionCouchMessageRecordRepository.saveMeta(MetaRecord metaRecord) CouchMessageRecordRepository.topics()CouchMessageRecordRepository.write(MessageRecord record)