dpyMwSubscriber.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 DpyMwSubscriber: public boost::enable_shared_from_this<DpyMwSubscriber>
{
    /********************************************************************************
     ***************************** PUBLIC FUNCTIONS *********************************
     ********************************************************************************/
public:
    DpyMwSubscriber(boost::asio::io_service& io, std::string pubUrl);
    ~DpyMwSubscriber();
    void start();
    void stop();
    void restart();

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

    /********************************************************************************
     **************************** PRIVATE VARIABLES *********************************
     ********************************************************************************/
private:
    boost::asio::io_service& mIo;
    azmq::sub_socket m_subscriberSocket; 
    std::string m_PubUrl; 
    bool m_working; 
    std::string m_message_subscriber; 
    /********************************************************************************
     **************************** PUBLIC VARIABLES *********************************
     ********************************************************************************/
public:
    std::function<void(const std::string &msg)> m_handler; 
};