29 #include <boost/format.hpp> 31 #include <rsc/os/HostInfo.h> 32 #include <rsc/os/ProcessInfo.h> 42 InConnector::InConnector(
BusPtr bus) :
43 logger(Logger::getLogger(
"rsb.transport.inprocess.InConnector")),
55 stream <<
"scope = " <<
scope;
64 throw std::runtime_error(
"Cannot set scope while active");
72 return boost::str(boost::format(
"inprocess://%1%:%2%")
73 % rsc::os::currentHostname()
74 % rsc::os::currentProcessId());
79 RSCDEBUG(
logger,
"Activating");
81 bus->addSink(boost::dynamic_pointer_cast<InConnector>(shared_from_this()));
87 RSCDEBUG(
logger,
"Deactivating");
91 bus->removeSink(
this);
rsc::logging::LoggerPtr logger
virtual void deactivate()
void printContents(std::ostream &stream) const
virtual void activate()
Activates the connector.
virtual Scope getScope() const
boost::shared_ptr< Bus > BusPtr
const std::string getTransportURL() const
Return an URL describing the transport kind and its configuration for this connector.
Scope is a descriptor for a hierarchical channel of the unified bus.
virtual void setScope(const Scope &scope)
Sets the scope this connector will send/receive events to/from.