RSB
0.19.0
|
#include <InPullConnector.h>
Public Member Functions | |
InPullConnector () | |
virtual | ~InPullConnector () |
void | setQualityOfServiceSpecs (const QualityOfServiceSpec &specs) |
Requests new QoS settings for publishing events. More... | |
void | handle (EventPtr event) |
Handle event. More... | |
EventPtr | raiseEvent (bool block) |
Public Member Functions inherited from rsb::transport::Connector | |
virtual | ~Connector () |
Public Member Functions inherited from rsb::filter::FilterObserver | |
FilterObserver () | |
virtual | ~FilterObserver () |
virtual void | notify (Filter *filter, const FilterAction::Types &at) |
virtual void | notify (ScopeFilter *filter, const FilterAction::Types &at) |
Public Member Functions inherited from rsb::transport::inprocess::InConnector | |
virtual | ~InConnector () |
void | printContents (std::ostream &stream) const |
virtual void | activate () |
Activates the connector. More... | |
virtual void | deactivate () |
virtual Scope | getScope () const |
virtual void | setScope (const Scope &scope) |
Sets the scope this connector will send/receive events to/from. More... | |
const std::string | getTransportURL () const |
Return an URL describing the transport kind and its configuration for this connector. More... | |
Public Member Functions inherited from rsb::eventprocessing::Handler | |
virtual | ~Handler () |
Static Public Member Functions | |
static rsb::transport::InPullConnector * | create (const rsc::runtime::Properties &args) |
Private Attributes | |
rsc::logging::LoggerPtr | logger |
rsc::threading::SynchronizedQueue< EventPtr > | queue |
Additional Inherited Members | |
Public Types inherited from rsb::transport::InPullConnector | |
typedef boost::shared_ptr< InPullConnector > | Ptr |
Public Types inherited from rsb::transport::InConnector | |
typedef boost::shared_ptr< InConnector > | Ptr |
Protected Member Functions inherited from rsb::transport::inprocess::InConnector | |
InConnector (BusPtr bus=getDefaultBus()) | |
Definition at line 48 of file InPullConnector.h.
rsb::transport::inprocess::InPullConnector::InPullConnector | ( | ) |
Definition at line 42 of file InPullConnector.cpp.
References create().
|
virtual |
Reimplemented from rsb::transport::InPullConnector.
Definition at line 50 of file InPullConnector.cpp.
|
static |
|
virtual |
Handle event.
event | The event that should be handled. |
TODO(jmoringe, 2011-11-07): This ensures not overwriting earlier receive timestamp added by different connector. However, thread-safety issue remains.
Implements rsb::eventprocessing::Handler.
Definition at line 56 of file InPullConnector.cpp.
References queue.
|
virtual |
Implements rsb::transport::InPullConnector.
Definition at line 68 of file InPullConnector.cpp.
References queue.
|
virtual |
Requests new QoS settings for publishing events.
Does not influence the receiving part.
specs | QoS specification |
UnsupportedQualityOfServiceException | requirements cannot be met |
Implements rsb::transport::Connector.
Definition at line 53 of file InPullConnector.cpp.
|
private |
Definition at line 63 of file InPullConnector.h.
|
private |
Definition at line 65 of file InPullConnector.h.
Referenced by handle(), and raiseEvent().