29 #include "../../Event.h" 30 #include "../../MetaData.h" 41 InPushConnector::InPushConnector() :
42 logger(Logger::getLogger(
"rsb.transport.inprocess.InPushConnector")) {
64 if (event->getMetaData().getReceiveTime() == 0) {
65 event->mutableMetaData().setReceiveTime();
67 for (HandlerList::iterator it = this->
handlers.begin(); it
Specification of desired quality of service settings for sending and receiving events.
void setQualityOfServiceSpecs(const QualityOfServiceSpec &specs)
Requests new QoS settings for publishing events.
void handle(EventPtr event)
Handle event.
static rsb::transport::InPushConnector * create(const rsc::runtime::Properties &args)
Objects of classes which implement this specialized InConnector interface provide the ability to rece...
boost::shared_ptr< Event > EventPtr
virtual ~InPushConnector()