lintel::IMessageQueueRepository Class Reference

#include <IMessageQueueRepository.h>

Inheritance diagram for lintel::IMessageQueueRepository:

Public Member Functions
virtual	~IMessageQueueRepository ()=default
virtual MessageQueueEntry	allMessageQueueNameOf (const std::string &name)=0
virtual std::vector< MessageQueueEntry >	allOf (const std::string &processName, const std::string &messageQueueName)=0
virtual Page< MessageQueueEntry >	pageOf (const std::string &processName, const std::string &messageQueueName, const std::optional< std::string > &afterName, std::size_t limit)=0
virtual std::vector< MessageQueueEntry >	allProcessNameOf (const std::string &processName)=0
virtual void	insertOf (const std::vector< MessageQueueEntry > &entries)=0
virtual void	deleteOf (const std::vector< MessageQueueEntry > &entries)=0

Detailed Description

Interface for message queue persistence operations.

Constructor & Destructor Documentation

~IMessageQueueRepository()

virtual lintel::IMessageQueueRepository::~IMessageQueueRepository ( )

virtualdefault

Member Function Documentation

allMessageQueueNameOf()

virtual MessageQueueEntry lintel::IMessageQueueRepository::allMessageQueueNameOf ( const std::string &  name )

pure virtual

Parameters

name	message queue name

Returns

the matching MessageQueueEntry

Implemented in lintel::MessageQueueRepository.

allOf()

virtual std::vector< MessageQueueEntry > lintel::IMessageQueueRepository::allOf ( const std::string &  processName, const std::string &  messageQueueName  )

pure virtual

Parameters

processName	process name filter
messageQueueName	queue name filter

Returns

matching entries

Implemented in lintel::MessageQueueRepository.

allProcessNameOf()

virtual std::vector< MessageQueueEntry > lintel::IMessageQueueRepository::allProcessNameOf ( const std::string &  processName )

pure virtual

Parameters

processName

filter by process name

Returns

all entries for the given process

Implemented in lintel::MessageQueueRepository.

deleteOf()

virtual void lintel::IMessageQueueRepository::deleteOf ( const std::vector< MessageQueueEntry > &  entries )

pure virtual

Delete entries.

Parameters

entries

entries to delete

Implemented in lintel::MessageQueueRepository.

insertOf()

virtual void lintel::IMessageQueueRepository::insertOf ( const std::vector< MessageQueueEntry > &  entries )

pure virtual

Insert entries.

Parameters

entries

entries to insert

Implemented in lintel::MessageQueueRepository.

pageOf()

virtual Page< MessageQueueEntry > lintel::IMessageQueueRepository::pageOf ( const std::string &  processName, const std::string &  messageQueueName, const std::optional< std::string > &  afterName, std::size_t  limit  )

pure virtual

Keyset-paginated queue query ordered by queue name ascending.

Parameters

processName	process name filter
messageQueueName	queue name filter
afterName	exclusive lower bound on the queue name; pass the previous page's nextAfter value (nullopt for first page)
limit	maximum number of entries per page

Returns

one page of entries plus continuation info

Implemented in lintel::MessageQueueRepository.

---

The documentation for this class was generated from the following file:

• src/include/lintel/features/base/repositories/IMessageQueueRepository.h