MessageSender.h

Go to the documentation of this file.

#ifndef __MESSAGESENDER_H_
#define __MESSAGESENDER_H_
 
#include "IMessageSender.h"
#include <bsp/IBSP.h>
#include <cpp-common/ICircularQueue.h>
#include <logger/ILogger.h>
#include <pheromones/HiveMindHostSerializer.h>
 
class MessageSender : public IMessageSender {
  public:
    MessageSender(ICircularQueue<MessageDTO>& inputQueue,
                  IHiveMindHostSerializer& serializer,
                  IBSP& bsp,
                  ILogger& logger);
 
    ~MessageSender() override = default;
 
    bool processAndSerialize() override;
 
  private:
    ICircularQueue<MessageDTO>& m_inputQueue;
    IHiveMindHostSerializer& m_serializer;
    IBSP& m_bsp;
    ILogger& m_logger;
};
 
#endif // __MESSAGESENDER_H_