subscribe_client.h

Go to the documentation of this file.

#ifndef CPPSERVER_NANOMSG_SUBSCRIBE_CLIENT_H
#define CPPSERVER_NANOMSG_SUBSCRIBE_CLIENT_H

#include "client.h"

namespace CppServer {
namespace Nanomsg {


class SubscribeClient : public Client
{
public:

    explicit SubscribeClient(const std::string& address, const std::string& topic = "", bool threading = true)
        : Client(CppServer::Nanomsg::Domain::Std, CppServer::Nanomsg::Protocol::Subscriber, address, threading)
    {
        socket().SetSocketOption(NN_SUB, NN_SUB_SUBSCRIBE, topic.data(), topic.size());
    }
    SubscribeClient(const SubscribeClient&) = delete;
    SubscribeClient(SubscribeClient&&) = default;
    virtual ~SubscribeClient() = default;

    SubscribeClient& operator=(const SubscribeClient&) = delete;
    SubscribeClient& operator=(SubscribeClient&&) = default;

private:
    using Client::Send;
    using Client::TrySend;
};

} // namespace Nanomsg
} // namespace CppServer

#endif // CPPSERVER_NANOMSG_SUBSCRIBE_CLIENT_H