RSB
0.7.0
|
#include <InPushConnector.h>
Public Member Functions | |
InPushConnector () | |
virtual | ~InPushConnector () |
std::string | getClassName () const |
void | setQualityOfServiceSpecs (const QualityOfServiceSpec &specs) |
Requests new QoS settings for publishing events. | |
void | handle (EventPtr event) |
Handle event. | |
Public Member Functions inherited from rsb::transport::InPushConnector | |
virtual void | addHandler (eventprocessing::HandlerPtr handler) |
virtual void | removeHandler (eventprocessing::HandlerPtr handler) |
Public Member Functions inherited from rsb::inprocess::InConnector | |
virtual | ~InConnector () |
void | printContents (std::ostream &stream) const |
virtual void | activate () |
Activates the connector. | |
virtual void | deactivate () |
virtual Scope | getScope () const |
virtual void | setScope (const Scope &scope) |
Sets the scope this connector will receive events from. |
Static Public Member Functions | |
static rsb::transport::InPushConnector * | create (const rsc::runtime::Properties &args) |
Private Attributes | |
rsc::logging::LoggerPtr | logger |
Additional Inherited Members | |
Public Types inherited from rsb::transport::InPushConnector | |
typedef boost::shared_ptr < InPushConnector > | Ptr |
Public Types inherited from rsb::transport::InConnector | |
typedef boost::shared_ptr < InConnector > | Ptr |
Protected Types inherited from rsb::transport::InPushConnector | |
typedef std::list < eventprocessing::HandlerPtr > | HandlerList |
Protected Member Functions inherited from rsb::inprocess::InConnector | |
InConnector () | |
Protected Attributes inherited from rsb::transport::InPushConnector | |
HandlerList | handlers |
Definition at line 46 of file InPushConnector.h.
rsb::inprocess::InPushConnector::InPushConnector | ( | ) |
Definition at line 40 of file InPushConnector.cpp.
|
virtual |
Reimplemented from rsb::transport::InPushConnector.
Definition at line 56 of file InPushConnector.cpp.
|
static |
string rsb::inprocess::InPushConnector::getClassName | ( | ) | const |
Definition at line 59 of file InPushConnector.cpp.
|
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 66 of file InPushConnector.cpp.
References rsb::transport::InPushConnector::handlers.
|
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 63 of file InPushConnector.cpp.
|
private |
Definition at line 61 of file InPushConnector.h.