MessageQueueRepository.h

Go to the documentation of this file.

#ifndef LINTEL_MESSAGEQUEUEREPOSITORY_H
#define LINTEL_MESSAGEQUEUEREPOSITORY_H
 
#include <lintel/core/configuration/DatabaseConnectionEntry.h>
#include <lintel/core/persistence/DatabaseConnectionConfigurations.h>
#include <lintel/features/base/configuration/MessageQueueEntry.h>
#include <lintel/features/base/models/Page.h>
#include <lintel/features/base/repositories/IMessageQueueRepository.h>
#include <memory>
#include <optional>
#include <vector>
 
namespace lintel {
class MessageQueueRepository : public IMessageQueueRepository
{
private:
  std::shared_ptr<DatabaseConnectionConfigurations> m_connectionConfigurations;
  std::shared_ptr<DatabaseConnectionEntry> m_connectionEntry;
 
public:
  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);
};
 
}// namespace lintel
#endif// LINTEL_MESSAGEQUEUEREPOSITORY_H