![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
Public Member Functions | |
ZmqMessageRouter (bool routable=true) | |
void | addRoute (const std::string &topic, AsyncMessageHandler handler) |
void | bind (const std::string &topic, const std::function< void(const std::vector< std::string > &args)> &handler) |
virtual void | handleMessage (const std::vector< std::string > &message) |
Public Attributes | |
bool | routable |
std::map< std::string, AsyncMessageHandler > | messageHandlers |
AsyncMessageHandler | defaultHandler |
Definition at line 22 of file zmq_message_router.h.
virtual void Datacratic::ZmqMessageRouter::handleMessage | ( | const std::vector< std::string > & | message | ) | [inline, virtual] |
Handle a message. The default implementation will call syncMessageHandler if it is defined; otherwise it calls handleSyncMessage and writes back the response to the socket.
Reimplemented from Datacratic::ZmqEventSource.
Definition at line 41 of file zmq_message_router.h.