MessageQueueService.h

Go to the documentation of this file.

#ifndef LINTEL_MESSAGEQUEUESERVICE_H
#define LINTEL_MESSAGEQUEUESERVICE_H
 
#include "lintel/features/base/configuration/MessageQueueEntry.h"
#include "lintel/features/base/repositories/IMessageQueueRepository.h"
#include <map>
#include <memory>
#include <string>
 
#include "lintel/core/configuration/Configuration.h"
#include "lintel/core/models/ProcessName.h"
#include "lintel/core/services/AbstractService.h"
#include "lintel/features/base/msg/Message.h"
#include "lintel/features/base/msg/MessageQueue.h"
 
namespace lintel {
class MessageQueueService : public AbstractService<MessageQueueService>
{
private:
  std::shared_ptr<ProcessName> m_processName;
  std::shared_ptr<IMessageQueueRepository> m_messageQueueRepository;
  std::map<std::string, std::shared_ptr<MessageQueueEntry>> m_configurationMap;
  std::map<std::string, std::shared_ptr<MessageQueue<Message>>> m_messageQueues{};
 
  static std::map<std::string, std::shared_ptr<MessageQueueEntry>> init(
    const std::shared_ptr<Configuration> &configuration);
 
public:
  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 {}
};
 
}// namespace lintel
#endif// LINTEL_MESSAGEQUEUESERVICE_H