dpyMwRouter.h

Go to the documentation of this file.

#pragma once

/********************************************************************************
 ********************************** INCLUDES ************************************
 ********************************************************************************/

#include <azmq/socket.hpp>
#include <azmq/message.hpp>
#include <azmq/util/scope_guard.hpp>

#include <boost/shared_ptr.hpp>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/function.hpp>
#include <boost/enable_shared_from_this.hpp>

class DpyMwRouter:

public boost::enable_shared_from_this<DpyMwRouter>
{
    /********************************************************************************
     ***************************** PUBLIC FUNCTIONS *********************************
     ********************************************************************************/
public:
    DpyMwRouter(boost::asio::io_service& io, std::string routerUrl);
    ~DpyMwRouter();
    void start();
    void stop();
    void doAsyncReceive();
    void doSend(std::string idDealer, std::string payload);

    /********************************************************************************
     **************************** PRIVATE VARIABLES *********************************
     ********************************************************************************/
private:
    boost::asio::io_service& mIo; 
    azmq::router_socket m_routerSocket; 
    std::string m_dpyMwRouterUrl; 
    bool m_working; 
    std::string m_message_router_id; 
    std::string m_message_router_payload; 
    /********************************************************************************
     **************************** PUBLIC VARIABLES *********************************
     ********************************************************************************/
public:
    std::function<void(const std::string &id, const std::string &payload)> m_handler; 
};