RSB
0.16.1
|
Objects of classes which implement this specialized InConnector interface provide the ability to receive events in push-style manner by means of one transport mechanism. More...
#include <InPushConnector.h>
Public Types | |
typedef boost::shared_ptr< InPushConnector > | Ptr |
Public Types inherited from rsb::transport::InConnector | |
typedef boost::shared_ptr< InConnector > | Ptr |
Public Member Functions | |
virtual | ~InPushConnector () |
virtual void | addHandler (eventprocessing::HandlerPtr handler) |
virtual void | removeHandler (eventprocessing::HandlerPtr handler) |
virtual void | setErrorStrategy (ParticipantConfig::ErrorStrategy strategy) |
A temporary hack to pass an ErrorStrategy to in push connectors so that they can be instructed by clients on what to do in case of asynchronous receive errors. More... | |
Public Member Functions inherited from rsb::transport::InConnector | |
virtual | ~InConnector () |
Public Member Functions inherited from rsb::transport::Connector | |
virtual | ~Connector () |
virtual void | setScope (const Scope &scope)=0 |
Sets the scope this connector will send/receive events to/from. More... | |
virtual void | activate ()=0 |
Activates the connector. More... | |
virtual void | deactivate ()=0 |
virtual void | setQualityOfServiceSpecs (const QualityOfServiceSpec &specs)=0 |
Requests new QoS settings for publishing events. More... | |
virtual const std::string | getTransportURL () const =0 |
Return an URL describing the transport kind and its configuration for this connector. More... | |
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) |
Protected Types | |
typedef std::list< eventprocessing::HandlerPtr > | HandlerList |
Protected Attributes | |
HandlerList | handlers |
Objects of classes which implement this specialized InConnector interface provide the ability to receive events in push-style manner by means of one transport mechanism.
Definition at line 48 of file InPushConnector.h.
|
protected |
Definition at line 68 of file InPushConnector.h.
typedef boost::shared_ptr<InPushConnector> rsb::transport::InPushConnector::Ptr |
Definition at line 50 of file InPushConnector.h.
|
virtual |
Reimplemented in rsb::transport::socket::InPushConnector, and rsb::transport::inprocess::InPushConnector.
Definition at line 34 of file InPushConnector.cpp.
|
virtual |
Definition at line 37 of file InPushConnector.cpp.
|
virtual |
Definition at line 41 of file InPushConnector.cpp.
|
virtual |
A temporary hack to pass an ErrorStrategy to in push connectors so that they can be instructed by clients on what to do in case of asynchronous receive errors.
The current convention is that ERROR_STRATEGY_LOG
and ERROR_STRATEGY_PRINT
shall use the declared channel for displaying the error once and afterwards connectors should stop processing.
strategy | the new error strategy to use |
Definition at line 45 of file InPushConnector.cpp.
|
protected |
Definition at line 70 of file InPushConnector.h.
Referenced by rsb::transport::inprocess::InPushConnector::handle(), and rsb::transport::socket::InPushConnector::handle().