29 #include <boost/format.hpp> 31 #include <rsc/os/HostInfo.h> 32 #include <rsc/os/ProcessInfo.h> 34 #include "../../MetaData.h" 45 OutConnector::OutConnector(
BusPtr bus) :
63 return boost::str(boost::format(
"inprocess://%1%:%2%")
64 % rsc::os::currentHostname()
65 % rsc::os::currentProcessId());
79 event->mutableMetaData().setSendTime();
80 this->
bus->handle(event);
Specification of desired quality of service settings for sending and receiving events.
void setScope(const Scope &scope)
Sets the scope this connector will send/receive events to/from.
void setQualityOfServiceSpecs(const QualityOfServiceSpec &specs)
Requests new QoS settings for publishing events.
OutConnector(BusPtr bus=getDefaultBus())
virtual const std::string getTransportURL() const
Return an URL describing the transport kind and its configuration for this connector.
void handle(rsb::EventPtr e)
Handle event.
void activate()
Activates the connector.
boost::shared_ptr< Bus > BusPtr
static rsb::transport::OutConnector * create(const rsc::runtime::Properties &args)
Objects of classes which implement this interface can be used to send events by means of one transpor...
boost::shared_ptr< Event > EventPtr
Scope is a descriptor for a hierarchical channel of the unified bus.