Program Listing for File async_publisher.cpp

↰ Return to documentation for file (src/o3ds/async_publisher.cpp)

#include "o3ds/async_publisher.h"

namespace O3DS
{

    bool AsyncPublisher::start(const char *url)
    {
        int ret;

        ret = nng_pub0_open(&mSocket);
        NNG_ERROR("Creating publish scocket");

        if ((ret = nng_listen(mSocket, url, NULL, 0)) < 0) {
            setError("Could not listen", ret);
            return false;
        }

        mState = Connector::STARTED;

        return true;
    }

}