29 #include "../../MetaData.h" 35 using namespace boost;
50 ConnectorBase(factory, converters, host, port, server, tcpnodelay),
51 logger(Logger::getLogger(
"rsb.transport.socket.InConnector")) {
63 RSCDEBUG(
logger,
"Activating");
65 getBus()->addSink(dynamic_pointer_cast<InConnector>(enable_shared_from_this<rsb::transport::InConnector>::shared_from_this()));
69 RSCDEBUG(
logger,
"Deactivating");
73 RSCDEBUG(
logger,
"Removing ourselves from sink list of bus " << bus);
74 bus->removeSink(
this);
81 RSCDEBUG(
logger,
"Quality of service not implemented");
Specification of desired quality of service settings for sending and receiving events.
virtual void deactivate()
boost::shared_ptr< Factory > FactoryPtr
rsc::logging::LoggerPtr logger
virtual Scope getScope() const
virtual void deactivate()
This class is intended to be used as a base class for connector classes of the socket-based transport...
BusPtr getBus()
Return the Bus object through which this connector is connected to a socket-based bus...
void setQualityOfServiceSpecs(const QualityOfServiceSpec &specs)
Requests new QoS settings for publishing events.
void printContents(std::ostream &stream) const
converter::ConverterSelectionStrategy< std::string >::Ptr ConverterSelectionStrategyPtr
boost::shared_ptr< Bus > BusPtr