#include <MessageQueueService.h>
Inheritance diagram for lintel::MessageQueueService:
Public Member Functions | |
| MessageQueueService (const std::shared_ptr< Configuration > &configuration, std::shared_ptr< ProcessName > processName, std::shared_ptr< IMessageQueueRepository > messageQueueRepository) | |
| std::unique_ptr< MessageQueue< Message > > | of (const std::string &name) |
| std::pair< MessageQueueEntry, int32_t > | numberMessagesOf (const MessageQueueEntry &entry) |
| void | onInitialize () override |
| void | onShutdown () override |
 Public Member Functions inherited from lintel::AbstractService< MessageQueueService > | |
| AbstractService ()=delete | |
| AbstractService (std::string processName, std::string instanceName) | |
| AbstractService (std::string processName) | |
| ShutdownPriority | shutdownPriorityOf () const override |
| const std::string & | getProcessName () const override |
| const std::string & | getInstanceName () const override |
| std::string_view | getClassName () const override |
| Public Member Functions inherited from lintel::AbstractServiceInterface | |
| virtual | ~AbstractServiceInterface ()=default |
Additional Inherited Members | |
| Protected Attributes inherited from lintel::AbstractService< MessageQueueService > | |
| std::vector< std::shared_ptr< PropertyBase > > | m_properties |
Detailed Description
Service that manages creation, retrieval, and lifecycle of MessageQueue instances.
Constructor & Destructor Documentation
◆ MessageQueueService()
| lintel::MessageQueueService::MessageQueueService | ( | const std::shared_ptr< Configuration > & | configuration, |
| std::shared_ptr< ProcessName > | processName, | ||
| std::shared_ptr< IMessageQueueRepository > | messageQueueRepository | ||
| ) |
constructor of message queue service
- Parameters
-
configuration parsed bootstrap configuration processName name of the current process messageQueueRepository repository holding the queue metadata
Member Function Documentation
◆ numberMessagesOf()
| std::pair< MessageQueueEntry, int32_t > lintel::MessageQueueService::numberMessagesOf | ( | const MessageQueueEntry & | entry | ) |
Get the number of messages for a given queue entry.
- Parameters
-
entry queue entry
- Returns
- pair of entry and message count
◆ of()
| std::unique_ptr< MessageQueue< Message > > lintel::MessageQueueService::of | ( | const std::string & | name | ) |
Returns a self-owned message queue (processName matches current process).
- Parameters
-
name of message queue
- Returns
- message queue instance
◆ onInitialize()
|
overridevirtual |
Default initialization does nothing; override in subclasses.
Reimplemented from lintel::AbstractService< MessageQueueService >.
◆ onShutdown()
|
inlineoverridevirtual |
Default shutdown does nothing; override in subclasses.
Reimplemented from lintel::AbstractService< MessageQueueService >.
The documentation for this class was generated from the following file:
- src/include/lintel/features/base/services/MessageQueueService.h
