dpyMwDealer.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>

namespace asio = boost::asio;
class DpyMwDealer: public boost::enable_shared_from_this<DpyMwDealer>
{

    /********************************************************************************
     ***************************** PUBLIC FUNCTIONS *********************************
     ********************************************************************************/
public:
    DpyMwDealer(boost::asio::io_service& io, std::string routerUrl);
    ~DpyMwDealer();
    void start();
    void stop();
    void restart();
    void sendData(std::string msg);

    /********************************************************************************
     ***************************** PRIVATE FUNCTIONS *********************************
     ********************************************************************************/
private:
    void doAsyncReceive();

    /********************************************************************************
     **************************** PRIVATE VARIABLES *********************************
     ********************************************************************************/
private:
    boost::asio::io_service& mIo;
    azmq::dealer_socket m_dealerSocket; 
    std::string m_RouterUrl; 
    bool m_working; 
    std::string m_message_router; 
    /********************************************************************************
     **************************** PUBLIC VARIABLES *********************************
     ********************************************************************************/
public:
    std::function<void(const std::string&)> m_handler; 
};