RSB
0.7.0
|
A class responsible of configuring the route that processes incoming events from one or more InConnector instances in one Listener. More...
#include <InRouteConfigurator.h>
Classes | |
class | Impl |
Public Types | |
typedef std::set < transport::InConnectorPtr > | ConnectorSet |
Public Member Functions | |
InRouteConfigurator (const Scope &scope, const ParticipantConfig &config) | |
virtual | ~InRouteConfigurator () |
std::string | getClassName () const |
void | printContents (std::ostream &stream) const |
virtual void | activate () |
virtual void | deactivate () |
const ParticipantConfig::EventProcessingStrategy & | getReceivingStrategyConfig () const |
EventReceivingStrategyPtr | getEventReceivingStrategy () const |
ConnectorSet | getConnectors () |
void | addConnector (transport::InConnectorPtr connector) |
void | removeConnector (transport::InConnectorPtr connector) |
void | filterAdded (filter::FilterPtr filter) |
void | filterRemoved (filter::FilterPtr filter) |
void | setQualityOfServiceSpecs (const QualityOfServiceSpec &specs) |
Define the desired quality of service specifications for published events. |
Private Member Functions | |
virtual EventReceivingStrategyPtr | createEventReceivingStrategy ()=0 |
Private Attributes | |
boost::scoped_ptr< Impl > | d |
A class responsible of configuring the route that processes incoming events from one or more InConnector instances in one Listener.
This responsibility includes updates to the route from adding or removing Filter or Handler instances.
Definition at line 73 of file InRouteConfigurator.h.
Definition at line 76 of file InRouteConfigurator.h.
rsb::eventprocessing::InRouteConfigurator::InRouteConfigurator | ( | const Scope & | scope, |
const ParticipantConfig & | config | ||
) |
Definition at line 63 of file InRouteConfigurator.cpp.
References d.
|
virtual |
Definition at line 71 of file InRouteConfigurator.cpp.
References d, and deactivate().
|
virtual |
Reimplemented in rsb::eventprocessing::PushInRouteConfigurator.
Definition at line 87 of file InRouteConfigurator.cpp.
References createEventReceivingStrategy(), and d.
void rsb::eventprocessing::InRouteConfigurator::addConnector | ( | transport::InConnectorPtr | connector | ) |
Definition at line 128 of file InRouteConfigurator.cpp.
References d.
|
privatepure virtual |
Implemented in rsb::eventprocessing::PullInRouteConfigurator.
Referenced by activate().
|
virtual |
Definition at line 102 of file InRouteConfigurator.cpp.
References d.
Referenced by ~InRouteConfigurator().
void rsb::eventprocessing::InRouteConfigurator::filterAdded | ( | filter::FilterPtr | filter | ) |
Definition at line 138 of file InRouteConfigurator.cpp.
References rsb::filter::FilterAction::ADD, and d.
void rsb::eventprocessing::InRouteConfigurator::filterRemoved | ( | filter::FilterPtr | filter | ) |
Definition at line 146 of file InRouteConfigurator.cpp.
References d, and rsb::filter::FilterAction::REMOVE.
string rsb::eventprocessing::InRouteConfigurator::getClassName | ( | ) | const |
Reimplemented in rsb::eventprocessing::PullInRouteConfigurator, and rsb::eventprocessing::PushInRouteConfigurator.
Definition at line 77 of file InRouteConfigurator.cpp.
InRouteConfigurator::ConnectorSet rsb::eventprocessing::InRouteConfigurator::getConnectors | ( | ) |
Definition at line 124 of file InRouteConfigurator.cpp.
References d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::activate(), and rsb::eventprocessing::PullInRouteConfigurator::createEventReceivingStrategy().
EventReceivingStrategyPtr rsb::eventprocessing::InRouteConfigurator::getEventReceivingStrategy | ( | ) | const |
Definition at line 120 of file InRouteConfigurator.cpp.
References d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::activate().
const ParticipantConfig::EventProcessingStrategy & rsb::eventprocessing::InRouteConfigurator::getReceivingStrategyConfig | ( | ) | const |
Definition at line 116 of file InRouteConfigurator.cpp.
References d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::createEventReceivingStrategy().
void rsb::eventprocessing::InRouteConfigurator::printContents | ( | std::ostream & | stream | ) | const |
Reimplemented in rsb::eventprocessing::PushInRouteConfigurator.
Definition at line 81 of file InRouteConfigurator.cpp.
References d.
void rsb::eventprocessing::InRouteConfigurator::removeConnector | ( | transport::InConnectorPtr | connector | ) |
Definition at line 133 of file InRouteConfigurator.cpp.
References d.
void rsb::eventprocessing::InRouteConfigurator::setQualityOfServiceSpecs | ( | const QualityOfServiceSpec & | specs | ) |
Define the desired quality of service specifications for published events.
specs | QoS specification |
UnsupportedQualityOfServiceException | requirements cannot be met |
Definition at line 154 of file InRouteConfigurator.cpp.
References d.
|
private |
Definition at line 110 of file InRouteConfigurator.h.
Referenced by activate(), addConnector(), deactivate(), filterAdded(), filterRemoved(), getConnectors(), getEventReceivingStrategy(), getReceivingStrategyConfig(), InRouteConfigurator(), printContents(), removeConnector(), setQualityOfServiceSpecs(), and ~InRouteConfigurator().