38 logger(Logger::getLogger(
"rsb.transport.socket.LifecycledBusServer")),
43 RSCDEBUG(
logger,
"Destructing");
47 this->
server->deactivate();
51 this->
server->addSink(sink);
55 this->
server->removeSink(sink);
59 this->
server->addConnection(connection);
63 this->
server->removeConnection(connection);
67 return this->
server->isTcpnodelay();
71 this->
server->handle(event);
75 RSCDEBUG(
logger,
"Activating");
80 RSCDEBUG(
logger,
"Deactivating");
81 this->
server->deactivate();
86 this->
server->handleIncoming(event, connection);
90 return this->
server->getTransportURL();
virtual bool isTcpnodelay() const
boost::shared_ptr< InConnector > InConnectorPtr
void handleIncoming(EventPtr event, BusConnectionPtr connection)
rsc::logging::LoggerPtr logger
virtual const std::string getTransportURL() const
Instances of this class receive events from a bus that is accessed via a socket connection.
boost::shared_ptr< BusServer > BusServerPtr
virtual ~LifecycledBusServer()
virtual void addConnection(BusConnectionPtr connection)
Adds connection to the list of connections of the bus.
virtual void removeSink(const InConnector *sink)
virtual void removeConnection(BusConnectionPtr connection)
Removes connection from the list of connections of this bus.
virtual void addSink(InConnectorPtr sink)
boost::shared_ptr< BusConnection > BusConnectionPtr
virtual void handle(EventPtr event)
Handle event.
virtual void printContents(std::ostream &stream) const
boost::shared_ptr< Event > EventPtr