subscribe_server.h

Go to the documentation of this file.

#ifndef CPPSERVER_NANOMSG_SUBSCRIBE_SERVER_H
#define CPPSERVER_NANOMSG_SUBSCRIBE_SERVER_H

#include "server.h"

namespace CppServer {
namespace Nanomsg {


class SubscribeServer : public Server
{
public:

    explicit SubscribeServer(const std::string& address)
        : Server(CppServer::Nanomsg::Domain::Std, CppServer::Nanomsg::Protocol::Publisher, address, false)
    {}
    SubscribeServer(const SubscribeServer&) = delete;
    SubscribeServer(SubscribeServer&&) = default;
    virtual ~SubscribeServer() = default;

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

private:
    using Server::Receive;
    using Server::TryReceive;
    using Server::onThreadInitialize;
    using Server::onThreadCleanup;
    using Server::onIdle;
    using Server::onReceived;
};

} // namespace Nanomsg
} // namespace CppServer

#endif // CPPSERVER_NANOMSG_SUBSCRIBE_SERVER_H