RSB
0.16.1
|
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 |
const std::set< std::string > | getTransportURLs () 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. More... | |
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 96 of file InRouteConfigurator.cpp.
References createEventReceivingStrategy(), and d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::activate().
void rsb::eventprocessing::InRouteConfigurator::addConnector | ( | transport::InConnectorPtr | connector | ) |
Definition at line 137 of file InRouteConfigurator.cpp.
References d.
|
privatepure virtual |
Implemented in rsb::eventprocessing::PushInRouteConfigurator, and rsb::eventprocessing::PullInRouteConfigurator.
Referenced by activate().
|
virtual |
Definition at line 111 of file InRouteConfigurator.cpp.
References d.
Referenced by ~InRouteConfigurator().
void rsb::eventprocessing::InRouteConfigurator::filterAdded | ( | filter::FilterPtr | filter | ) |
Definition at line 147 of file InRouteConfigurator.cpp.
References rsb::filter::FilterAction::ADD, and d.
void rsb::eventprocessing::InRouteConfigurator::filterRemoved | ( | filter::FilterPtr | filter | ) |
Definition at line 155 of file InRouteConfigurator.cpp.
References d, and rsb::filter::FilterAction::REMOVE.
string rsb::eventprocessing::InRouteConfigurator::getClassName | ( | ) | const |
Definition at line 77 of file InRouteConfigurator.cpp.
InRouteConfigurator::ConnectorSet rsb::eventprocessing::InRouteConfigurator::getConnectors | ( | ) |
Definition at line 133 of file InRouteConfigurator.cpp.
References d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::activate(), rsb::eventprocessing::PullInRouteConfigurator::createEventReceivingStrategy(), and rsb::eventprocessing::PushInRouteConfigurator::setErrorStrategy().
EventReceivingStrategyPtr rsb::eventprocessing::InRouteConfigurator::getEventReceivingStrategy | ( | ) | const |
Definition at line 129 of file InRouteConfigurator.cpp.
References d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::activate().
const ParticipantConfig::EventProcessingStrategy & rsb::eventprocessing::InRouteConfigurator::getReceivingStrategyConfig | ( | ) | const |
Definition at line 125 of file InRouteConfigurator.cpp.
References d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::createEventReceivingStrategy().
const std::set< std::string > rsb::eventprocessing::InRouteConfigurator::getTransportURLs | ( | ) | const |
Definition at line 87 of file InRouteConfigurator.cpp.
References d.
void rsb::eventprocessing::InRouteConfigurator::printContents | ( | std::ostream & | stream | ) | const |
Definition at line 81 of file InRouteConfigurator.cpp.
References d.
Referenced by rsb::eventprocessing::PushInRouteConfigurator::printContents().
void rsb::eventprocessing::InRouteConfigurator::removeConnector | ( | transport::InConnectorPtr | connector | ) |
Definition at line 142 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 163 of file InRouteConfigurator.cpp.
References d.
|
private |
Definition at line 112 of file InRouteConfigurator.h.
Referenced by activate(), addConnector(), deactivate(), filterAdded(), filterRemoved(), getConnectors(), getEventReceivingStrategy(), getReceivingStrategyConfig(), getTransportURLs(), InRouteConfigurator(), printContents(), removeConnector(), setQualityOfServiceSpecs(), and ~InRouteConfigurator().