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)