Uses of Record Class
net.blakez.bppmq.core.queue.MessageRecord

Packages that use MessageRecord

Package	Description
net.blakez.bppmq.core.queue
net.blakez.bppmq.infra.data.queue

Uses of MessageRecord in net.blakez.bppmq.core.queue

Methods in net.blakez.bppmq.core.queue that return types with arguments of type MessageRecord

Modifier and Type	Method	Description
Result<MessageRecord>	MessageRecordRepository.delete(String topic, long index)	Deletes a message by topic and index.
Result<MessageRecord>	MessageRecordRepository.deleteID(UUID uuid)	Deletes a message by its UUID.
Result<List<MessageRecord>>	MessageRecordRepository.list(String topic, long startIndex, long batchSize)	Lists messages for a topic starting from a specific index.
Result<MessageRecord>	MessageRecordRepository.lookupID(UUID uuid)	Reads a message by its UUID.
Result<MessageRecord>	PushPullQueueCore.pull(String topic, long index)	Pulls a single message from the specified topic at the given index.
Result<List<MessageRecord>>	PushPullQueueCore.pullBatch(String topic, long index, long batchSize)	Pulls a batch of messages from the specified topic starting at the given index.
Result<List<MessageRecord>>	PushPullQueueCore.pullFrom(String topic, long from, long batchSize)	Pulls messages from the specified topic starting from the given index.
Result<MessageRecord>	PushPullQueueCore.push(String topic, String message)	Pushes a single message to the specified topic.
Result<MessageRecord>	MessageRecordRepository.read(String topic, long index)	Reads a specific message by topic and index.
Result<MessageRecord>	MessageRecordRepository.write(MessageRecord record)	Writes a new message record.

Methods in net.blakez.bppmq.core.queue with parameters of type MessageRecord

Modifier and Type	Method	Description
Result<MessageRecord>	MessageRecordRepository.write(MessageRecord record)	Writes a new message record.

Uses of MessageRecord in net.blakez.bppmq.infra.data.queue

Methods in net.blakez.bppmq.infra.data.queue that return MessageRecord

Modifier and Type	Method	Description
MessageRecord	MessageRecordDeserializer.deserialize(com.fasterxml.jackson.core.JsonParser jp, com.fasterxml.jackson.databind.DeserializationContext dc)

Methods in net.blakez.bppmq.infra.data.queue that return types with arguments of type MessageRecord

Modifier and Type	Method	Description
Result<MessageRecord>	CouchMessageRecordRepository.delete(String topic, long index)
Result<MessageRecord>	CouchMessageRecordRepository.deleteID(UUID uuid)
Result<List<MessageRecord>>	CouchMessageRecordRepository.list(String topic, long startIndex, long batchSize)
Result<MessageRecord>	CouchMessageRecordRepository.lookupID(UUID uuid)
Result<MessageRecord>	CouchMessageRecordRepository.read(String topic, long index)
Result<MessageRecord>	CouchMessageRecordRepository.write(MessageRecord record)

Methods in net.blakez.bppmq.infra.data.queue with parameters of type MessageRecord

Modifier and Type	Method	Description
void	MessageRecordSerializer.serialize(MessageRecord record, com.fasterxml.jackson.core.JsonGenerator jg, com.fasterxml.jackson.databind.SerializerProvider sp)
Result<MessageRecord>	CouchMessageRecordRepository.write(MessageRecord record)

Constructor parameters in net.blakez.bppmq.infra.data.queue with type arguments of type MessageRecord

Modifier	Constructor	Description
	MessageRecordSerializer(Class<MessageRecord> vc)