![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
#include <zmq_named_pub_sub.h>
Public Member Functions | |
ZmqNamedPublisher (std::shared_ptr< zmq::context_t > context, int messageBufferSize=10000) | |
void | init (std::shared_ptr< ConfigurationService > config, const std::string &endpointName, const std::string &identity="") |
std::string | bindTcp (PortRange const &portRange=PortRange(), std::string host="") |
void | shutdown () |
template<typename Head , typename... Tail> | |
void | encodeAll (std::vector< zmq::message_t > &messages, Head head, Tail &&...tail) |
template<typename... Tail> | |
void | encodeAll (std::vector< zmq::message_t > &messages, const std::vector< std::string > &head, Tail &&...tail) |
void | encodeAll (std::vector< zmq::message_t > &messages) |
template<typename... Args> | |
void | publish (const std::string &channel, Args &&...args) |
Class that publishes messages. It also knows what is connected to it.
Definition at line 25 of file zmq_named_pub_sub.h.