EventBusService.h

Go to the documentation of this file.

#ifndef LINTEL_EVENTBUSSERVICE_H
#define LINTEL_EVENTBUSSERVICE_H
 
#include <map>
#include <memory>
#include <string>
 
#include "lintel/core/configuration/Configuration.h"
#include "lintel/core/models/ProcessName.h"
#include "lintel/core/services/AbstractService.h"
#include "lintel/features/base/configuration/EventBusEntry.h"
#include "lintel/features/base/events/EventBus.h"
#include "lintel/features/base/services/SharedMemorySegmentManager.h"
#include "lintel/features/base/services/SharedMemoryService.h"
 
namespace lintel {
class EventBusService : public AbstractService<EventBusService>
{
private:
  std::shared_ptr<ProcessName> m_processName;
  std::shared_ptr<SharedMemoryService> m_sharedMemoryService;
  std::shared_ptr<SharedMemorySegmentManager> m_segmentManager;
  std::map<std::string, std::shared_ptr<EventBusEntry>> m_configurationMap;
  std::map<std::string, EventBus *> m_buses;
  std::map<std::string, std::size_t> m_generations;
 
  static std::map<std::string, std::shared_ptr<EventBusEntry>> init(
    const std::shared_ptr<Configuration> &configuration);
 
  EventBusConfig configOf(const std::shared_ptr<EventBusEntry> &entry);
 
  EventBus &resolve(const std::shared_ptr<EventBusEntry> &entry);
 
public:
  EventBusService(const std::shared_ptr<Configuration> &configuration,
    std::shared_ptr<ProcessName> processName,
    std::shared_ptr<SharedMemoryService> sharedMemoryService,
    std::shared_ptr<SharedMemorySegmentManager> segmentManager);
 
  std::shared_ptr<IEventBus> of(const std::string &name);
 
  void onInitialize() override;
 
  void onShutdown() override {}
};
 
}// namespace lintel
#endif// LINTEL_EVENTBUSSERVICE_H