MessageBus.hpp

Go to the documentation of this file.

#ifndef IFW_CTD_MPTK_MESSAGE_BUS_HPP_
#define IFW_CTD_MPTK_MESSAGE_BUS_HPP_

#include <string>
#include <queue>
#include <iostream>

#include "ctd/defines/defines.hpp"

#include "ctd/mptk/Message.hpp"
#include "ctd/mptk/Response.hpp"

namespace ctd {
namespace mptk {


class MessageBus {
public:

    MessageBus();

    ~MessageBus();

    MessageBus& RegisterThread(const std::string& thread_id);

    void SendMessage(const Message& message);

    bool ReceiveMessage(const std::string& receiver_thread_id,
                        const double time_out,
                        bool& timed_out,
                        Message& message);

    void SendResponse(Response& response);

    bool ReceiveResponse(const std::string& receiver_thread_id,
                         const double time_out,
                         bool& timed_out,
                         Response& response);

    std::string Print() const;

private:
    std::string m_id; // Message Bus ID.

    // Message receiver Thread ID to message objects list.
    std::map<std::string, std::list<Message> > m_message_registry;

    // Response receiver Thread ID to response objects list.
    std::map<std::string, std::list<Response> > m_response_registry;

    ctd::defines::List<std::string> m_threads;
};

} // namespace mptk
} // namespace ctd

#endif // IFW_CTD_MPTK_MESSAGE_BUS_HPP_