lintel::MessageQueueRepository Class Reference

#include <MessageQueueRepository.h>

Inheritance diagram for lintel::MessageQueueRepository:

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

Detailed Description

Database-backed implementation of IMessageQueueRepository.

Constructor & Destructor Documentation

MessageQueueRepository()

lintel::MessageQueueRepository::MessageQueueRepository

(

const std::shared_ptr< DatabaseConnectionConfigurations > &

connectionConfigurations

)

Constructor.

Parameters

connectionConfigurations

database connection configuration

Member Function Documentation

allMessageQueueNameOf()

MessageQueueEntry lintel::MessageQueueRepository::allMessageQueueNameOf ( const std::string &  name )

virtual

Parameters

name	message queue name

Returns

the matching MessageQueueEntry

Implements lintel::IMessageQueueRepository.

allOf()

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

virtual

Parameters

processName	process name filter
messageQueueName	queue name filter

Returns

matching entries

Implements lintel::IMessageQueueRepository.

allProcessNameOf()

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

virtual

Parameters

processName

filter by process name

Returns

all entries for the given process

Implements lintel::IMessageQueueRepository.

deleteOf()

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

virtual

Delete entries.

Parameters

entries

entries to delete

Implements lintel::IMessageQueueRepository.

insertOf()

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

virtual

Insert entries.

Parameters

entries

entries to insert

Implements lintel::IMessageQueueRepository.

pageOf()

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

overridevirtual

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

Implements lintel::IMessageQueueRepository.

---

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

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