RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
#include <publish_output.h>
Public Member Functions | |
PublishOutput () | |
PublishOutput (zmq::context_t &context) | |
PublishOutput (std::shared_ptr< zmq::context_t > context) | |
void | bind (const std::string &uri) |
virtual void | logMessage (const std::string &channel, const std::string &message) |
virtual void | close () |
Public Attributes | |
std::shared_ptr< zmq::context_t > | context |
Zeromq context that we use. | |
zmq::socket_t | sock |
Socket that we publish to. |
Class that publishes messages to a zeromq socket. Other things can subscribe to it to get the results.
Definition at line 23 of file publish_output.h.
Create a logger with its own zeromq context.
Definition at line 20 of file publish_output.cc.
void Datacratic::PublishOutput::bind | ( | const std::string & | uri | ) |
Bind it to a port. Other processes can connect to this to subscribe to the logging feed.
Definition at line 47 of file publish_output.cc.
void Datacratic::PublishOutput::close | ( | ) | [virtual] |
Should close whatever resources are being used by the output and join any threads that it's created.
Implements Datacratic::LogOutput.
Definition at line 64 of file publish_output.cc.
void Datacratic::PublishOutput::logMessage | ( | const std::string & | channel, |
const std::string & | message | ||
) | [virtual] |
This is the method that will be called whenever we need to log a message to something.
Implements Datacratic::LogOutput.
Definition at line 55 of file publish_output.cc.