#include <broker.hpp>

Public Member Functions
	Broker (zio::socket_t &sock)

	~Broker ()

void	start ()

void	proc_one ()
	Process one input on socket. More...

void	proc_heartbeat (time_unit_t heartbeat_at)
	Do heartbeat processing given next heatbeat time. More...

Detailed Description

The ZIO domo broker class

Definition at line 17 of file broker.hpp.

Constructor & Destructor Documentation

Broker::Broker ( zio::socket_t & sock )

Create a broker with a ROUTER or SERVER socket already bound. Caller must keep socket, eg to mix with others in an actor's poller.

Definition at line 18 of file domo_broker.cpp.

Broker::~Broker ( )

Definition at line 37 of file domo_broker.cpp.

void Broker::proc_heartbeat ( time_unit_t heartbeat_at )

Do heartbeat processing given next heatbeat time.

Definition at line 69 of file domo_broker.cpp.

void Broker::proc_one ( )

Process one input on socket.

Definition at line 50 of file domo_broker.cpp.

void Broker::start ( )

Begin brokering (run forever). The guts of this method need to be reimplemented if proc_*() are called instead.

Definition at line 85 of file domo_broker.cpp.

The documentation for this class was generated from the following files: