29 #include "../../MetaData.h"
35 using namespace boost;
37 using namespace rsc::logging;
38 using namespace rsc::runtime;
50 logger(Logger::getLogger(
"rsb.transport.socket.InConnector")) {
62 RSCDEBUG(
logger,
"Activating");
64 getBus()->addSink(dynamic_pointer_cast<InConnector>(enable_shared_from_this<rsb::transport::InConnector>::shared_from_this()));
68 RSCDEBUG(
logger,
"Deactivating");
72 RSCDEBUG(
logger,
"Removing ourselves from sink list of bus " << bus);
73 bus->removeSink(
this);
80 RSCWARN(
logger,
"Quality of service not implemented");
Specification of desired quality of service settings for sending and receiving events.
virtual void deactivate()
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