IMessageQueueRepository.h

Go to the documentation of this file.

#ifndef LINTEL_IMESSAGEQUEUEREPOSITORY_H
#define LINTEL_IMESSAGEQUEUEREPOSITORY_H
 
#include <memory>
#include <optional>
#include <string>
#include <vector>
 
#include "lintel/features/base/models/Page.h"
 
namespace lintel {
class MessageQueueEntry;
 
class IMessageQueueRepository
{
public:
  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;
};
 
}// namespace lintel
#endif// LINTEL_IMESSAGEQUEUEREPOSITORY_H