MessageQueueDto.h

Go to the documentation of this file.

#ifndef LINTEL_MESSAGEQUEUEDTO_H
#define LINTEL_MESSAGEQUEUEDTO_H
 
#include "lintel/core/models/JsonSerializable.h"
#include "lintel/features/base/configuration/MessageQueueEntry.h"
#include <cstdint>
#include <rapidjson/document.h>
#include <rapidjson/stringbuffer.h>
#include <string>
 
namespace lintel {
class MessageQueueDto : public JsonSerializable
{
  std::string m_name;
  std::string m_process;
  int32_t m_maxMessages{};
  int32_t m_messages{};
 
  static struct Shapes
  {
    const char *const NAME = "NAME";
    const char *const PROCESS = "PROCESS";
    const char *const MAX_MESSAGES = "MAX_MESSAGES";
    const char *const MESSAGES = "MESSAGES";
  } m_shape;
 
public:
  MessageQueueDto() = default;
 
  MessageQueueDto(const MessageQueueEntry &messsageQueueEntry, int32_t messages);
 
  [[nodiscard]] const std::string &getName() const;
 
  [[nodiscard]] const std::string &getProcess() const;
 
  [[nodiscard]] int32_t getMaxMessages() const;
 
  [[nodiscard]] int32_t getMessages() const;
 
  void serialize(rapidjson::Writer<rapidjson::StringBuffer> *writer) const override;
 
  bool deserialize(const rapidjson::Value &obj) override;
};
 
}// namespace lintel
#endif// LINTEL_MESSAGEQUEUEDTO_H