30 #include "../../MetaData.h" 42 InPullConnector::InPullConnector() :
43 logger(Logger::getLogger(
"rsb.transport.inprocess.InPullConnector")) {
61 if (event->getMetaData().getReceiveTime() == 0) {
62 event->mutableMetaData().setReceiveTime();
65 this->
queue.push(event);
70 return this->
queue.pop();
73 return this->
queue.tryPop();
74 }
catch (
const QueueEmptyException&) {
Specification of desired quality of service settings for sending and receiving events.
void handle(EventPtr event)
Handle event.
static rsb::transport::InPullConnector * create(const rsc::runtime::Properties &args)
Objects of classes which implement this specialized InConnector interface provide the ability to rece...
virtual ~InPullConnector()
boost::shared_ptr< Event > EventPtr
void setQualityOfServiceSpecs(const QualityOfServiceSpec &specs)
Requests new QoS settings for publishing events.
rsc::threading::SynchronizedQueue< EventPtr > queue
EventPtr raiseEvent(bool block)