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

Class CouchMessageRecordRepository

java.lang.Object

net.blakez.bppmq.infra.data.queue.CouchMessageRecordRepository

All Implemented Interfaces:

MessageRecordRepository

public class CouchMessageRecordRepository
extends Object
implements MessageRecordRepository

CouchDB implementation of MessageRecordRepository.

Author:

Peter Blakeley : @pblakez pb@blakez.org

Constructor Summary

Constructors

Constructor	Description
CouchMessageRecordRepository(com.attain.db.couch2.AttainCouchDB2 cdb)

Method Summary

Modifier and Type	Method	Description
Result<MessageRecord>	delete(String topic, long index)	Deletes a message by topic and index.
Result<MessageRecord>	deleteID(UUID uuid)	Deletes a message by its UUID.
Result<List<MessageRecord>>	list(String topic, long startIndex, long batchSize)	Lists messages for a topic starting from a specific index.
Result<MessageRecord>	lookupID(UUID uuid)	Reads a message by its UUID.
Result<MetaRecord>	meta(String topic)	Retrieves metadata for a given topic.
Result<MessageRecord>	read(String topic, long index)	Reads a specific message by topic and index.
Result<MetaRecord>	saveMeta(MetaRecord metaRecord)	Saves or updates metadata for a topic.
Result<List<String>>	topics()	Retrieves a list of all available topic names.
Result<MessageRecord>	write(MessageRecord record)	Writes a new message record.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CouchMessageRecordRepository

public CouchMessageRecordRepository(com.attain.db.couch2.AttainCouchDB2 cdb)

Method Details

meta

public Result<MetaRecord> meta(String topic)

Description copied from interface: MessageRecordRepository

Retrieves metadata for a given topic.

Specified by:

meta in interface MessageRecordRepository

Parameters:

topic - The topic name.

Returns:

A Result containing the MetaRecord or errors.

list

public Result<List<MessageRecord>> list(String topic,
 long startIndex,
 long batchSize)

Description copied from interface: MessageRecordRepository

Lists messages for a topic starting from a specific index.

Specified by:

list in interface MessageRecordRepository

Parameters:

topic - The topic name.

startIndex - The starting index for the list.

batchSize - The maximum number of messages to retrieve.

Returns:

A Result containing a list of MessageRecords or errors.

read

public Result<MessageRecord> read(String topic,
 long index)

Description copied from interface: MessageRecordRepository

Reads a specific message by topic and index.

Specified by:

read in interface MessageRecordRepository

Parameters:

topic - The topic name.

index - The index of the message.

Returns:

A Result containing the MessageRecord or errors.

write

public Result<MessageRecord> write(MessageRecord record)

Description copied from interface: MessageRecordRepository

Writes a new message record.

Specified by:

write in interface MessageRecordRepository

Parameters:

record - The MessageRecord to write.

Returns:

A Result containing the written MessageRecord or errors.

delete

public Result<MessageRecord> delete(String topic,
 long index)

Description copied from interface: MessageRecordRepository

Deletes a message by topic and index.

Specified by:

delete in interface MessageRecordRepository

Parameters:

topic - The topic name.

index - The index of the message to deleteID.

Returns:

A Result containing the deleted MessageRecord or errors.

deleteID

public Result<MessageRecord> deleteID(UUID uuid)

Description copied from interface: MessageRecordRepository

Deletes a message by its UUID.

Specified by:

deleteID in interface MessageRecordRepository

Parameters:

uuid - The UUID of the message to deleteID.

Returns:

A Result containing the deleted MessageRecord or errors.

lookupID

public Result<MessageRecord> lookupID(UUID uuid)

Description copied from interface: MessageRecordRepository

Reads a message by its UUID.

Specified by:

lookupID in interface MessageRecordRepository

Parameters:

uuid - The UUID of the message to lookupID.

Returns:

A Result containing the MessageRecord or errors.

topics

public Result<List<String>> topics()

Description copied from interface: MessageRecordRepository

Retrieves a list of all available topic names.

Specified by:

topics in interface MessageRecordRepository

Returns:

A Result containing a list of topic strings or errors.

saveMeta

public Result<MetaRecord> saveMeta(MetaRecord metaRecord)

Description copied from interface: MessageRecordRepository

Saves or updates metadata for a topic.

Specified by:

saveMeta in interface MessageRecordRepository

Parameters:

metaRecord - The MetaRecord to save.

Returns:

A Result containing the saved MetaRecord or errors.