MessageQueueComponent.h

Go to the documentation of this file.

#ifndef LINTEL_MESSAGEQUEUECOMPONENT_H
#define LINTEL_MESSAGEQUEUECOMPONENT_H
 
#include <memory>
 
#include "lintel/core/configuration/Component.h"
#include "lintel/core/configuration/Entry.h"
#include "lintel/core/configuration/EnvironmentConfiguration.h"
 
namespace lintel {
class MessageQueueComponent : public Component
{
private:
  static const struct Shapes
  {
    const char *const CONFIG_ROOT = "MessageQueues";
    const char *const MESSAGE_QUEUE_ROOT = "MessageQueue";
    const char *const MESSAGE_QUEUE_NAME = "name";
    const char *const MESSAGE_QUEUE_PROCESS_NAME = "process_name";
    const char *const MESSAGE_QUEUE_MAX_MESSAGES = "max_messages";
    const char *const MESSAGE_QUEUE_REMOVE_ON_SHUTDOWN = "remove_on_shutdown";
  } shape;
 
public:
  MessageQueueComponent();
 
  std::vector<std::shared_ptr<Entry>>
    parse(const std::string &content, int32_t lineOffset, const std::string &fileName) override;
};
 
}// namespace lintel
#endif// LINTEL_MESSAGEQUEUECOMPONENT_H