![]() |
RTBKit
0.9
Open-source framework to create real-time ad bidding systems.
|
#include <zmq_endpoint.h>
Public Member Functions | |
ZmqNamedClientBusProxy (std::shared_ptr< zmq::context_t > context) | |
void | init (std::shared_ptr< ConfigurationService > config, const std::string &identity="") |
void | shutdown () |
virtual void | onConnect (const std::string &where) |
virtual void | onDisconnect (const std::string &where) |
virtual void | handleMessage (const std::vector< std::string > &message) |
Public Attributes | |
ZmqEventSource::AsyncMessageHandler | messageHandler |
Date | lastHeartbeat |
double | timeout |
Class designed to go on the other end of a zeromq named client bus. This takes care of sending the keepalives and will allow the other end to detect when the connection is broken.
Definition at line 1033 of file zmq_endpoint.h.
virtual void Datacratic::ZmqNamedClientBusProxy::onConnect | ( | const std::string & | source | ) | [inline, virtual] |
Function that will be called when we make a new connection to a remote service provider.
Reimplemented from Datacratic::ZmqNamedProxy.
Definition at line 1089 of file zmq_endpoint.h.
virtual void Datacratic::ZmqNamedClientBusProxy::onDisconnect | ( | const std::string & | source | ) | [inline, virtual] |
Function that will be called when we lose a connection to a remote service provider.
Reimplemented from Datacratic::ZmqNamedProxy.
Definition at line 1099 of file zmq_endpoint.h.