![]() |
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.
1.7.6.1