soa/logger/publish_output.h

/* publish_output.h                                                -*- C++ -*-
   Jeremy Barnes, 29 May 2011
   Copyright (c) 2011 Datacratic.  All rights reserved.

   Output that publishes on a zeromq socket.
*/

#ifndef __logger__publish_output_h__
#define __logger__publish_output_h__

#include "logger.h"

namespace Datacratic {

/*****************************************************************************/
/* PUBLISH OUTPUT                                                            */
/*****************************************************************************/

struct PublishOutput : public LogOutput {

    PublishOutput();

    PublishOutput(zmq::context_t & context);

    PublishOutput(std::shared_ptr<zmq::context_t> context);

    virtual ~PublishOutput();

    void bind(const std::string & uri);

    virtual void logMessage(const std::string & channel,
                            const std::string & message);

    virtual void close();

    std::shared_ptr<zmq::context_t> context;

    zmq::socket_t sock;
};




} // namespace Datacratic


#endif /* __logger__publish_output_h__ */