MessageQueueBootstrapPlugin.h

Go to the documentation of this file.

#ifndef LINTEL_MESSAGEQUEUEBOOTSTRAPPLUGIN_H
#define LINTEL_MESSAGEQUEUEBOOTSTRAPPLUGIN_H
 
#include "lintel/core/persistence/DatabaseConnectionConfigurations.h"
#include "lintel/core/plugins/BootstrapPlugin.h"
#include "lintel/features/base/provider/GroupProvider.h"
#include <lintel/core/configuration/Configuration.h>
#include <lintel/core/models/ProcessName.h>
#include <lintel/features/base/repositories/IMessageQueueRepository.h>
 
namespace lintel {
class MessageQueueBootstrapPlugin : public BootstrapPlugin
{
private:
  std::shared_ptr<IMessageQueueRepository> m_messageQueueRepository;
  std::shared_ptr<Configuration> m_configuration;
  std::shared_ptr<DatabaseConnectionEntry> m_connectionEntry;
  std::shared_ptr<ProcessName> m_processName;
 
public:
  explicit MessageQueueBootstrapPlugin(
    const std::shared_ptr<DatabaseConnectionConfigurations> &connectionConfigurations,
    std::shared_ptr<Configuration> configuration,
    std::shared_ptr<IMessageQueueRepository> messageQueueRepository,
    std::shared_ptr<ProcessName> processName);
 
  void onStart() override;
 
  BootstrapSequence getPriority() override;
};
 
}// namespace lintel
#endif// LINTEL_MESSAGEQUEUEBOOTSTRAPPLUGIN_H