Instances of this class provide access to a socket-based bus for local and remote bus clients. More...

#include <BusServer.h>

Inheritance diagram for rsb::transport::socket::BusServer:

Collaboration diagram for rsb::transport::socket::BusServer:

Public Member Functions
	BusServer (AsioServiceContextPtr asioService, bool tcpnodelay)

virtual	~BusServer ()

virtual void	activate ()=0

virtual void	deactivate ()=0

virtual void	handleIncoming (EventPtr event, BusConnectionPtr connection)=0

Public Member Functions inherited from rsb::transport::socket::Bus
	Bus (AsioServiceContextPtr asioService, bool tcpnodelay=false)

virtual	~Bus ()

virtual void	addSink (InConnectorPtr sink)

virtual void	removeSink (InConnector *sink)

virtual void	addConnection (BusConnectionPtr connection)
	Adds connection to the list of connections of the bus. More...

virtual void	removeConnection (BusConnectionPtr connection)
	Removes connection from the list of connections of this bus. More...

virtual bool	isTcpnodelay () const

virtual void	handle (EventPtr event)
	Handle event. More...

virtual AsioServiceContextPtr	getService () const

virtual void	printContents (std::ostream &stream) const

virtual const std::string	getTransportURL () const

Public Member Functions inherited from rsb::eventprocessing::Handler
virtual	~Handler ()

Additional Inherited Members
Protected Types inherited from rsb::transport::socket::Bus
typedef std::list< BusConnectionPtr >	ConnectionList

Protected Member Functions inherited from rsb::transport::socket::Bus
ConnectionList	getConnections () const

boost::recursive_mutex &	getConnectionLock ()

Detailed Description

Instances of this class provide access to a socket-based bus for local and remote bus clients.

Remote clients can connect to a server socket in order to send and receive events through the resulting socket connection.

Local clients (connectors) use the usual Bus interface to receive events submitted by remote clients and submit events which will be distributed to remote clients by the BusServer.