RTBKit  0.9
Open-source framework to create real-time ad bidding systems.
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator
Public Member Functions | Public Attributes
Datacratic::ZmqNamedClientBusProxy Struct Reference

#include <zmq_endpoint.h>

Inheritance diagram for Datacratic::ZmqNamedClientBusProxy:
Datacratic::ZmqNamedProxy Datacratic::MessageLoop Datacratic::Epoller Datacratic::AsyncEventSource

List of all members.

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

Detailed Description

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.


Member Function Documentation

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.


The documentation for this struct was generated from the following file:
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator