29 #include <boost/bind.hpp>
35 using namespace boost;
37 using namespace rsc::runtime;
38 using namespace rsc::logging;
40 using namespace rsb::transport;
43 namespace eventprocessing {
45 PushInRouteConfigurator::PushInRouteConfigurator(
const Scope& scope,
48 logger(Logger::getLogger(
"rsb.eventprocessing.PushInRouteConfigurator")),
56 return "PushInRouteConfigurator";
77 for (InRouteConfigurator::ConnectorSet::const_iterator it =
78 connectors.begin(); it != connectors.end(); ++it) {
83 connector->addHandler(
104 for (InRouteConfigurator::ConnectorSet::const_iterator it =
105 connectors.begin(); it != connectors.end(); ++it) {
117 RSCDEBUG(
logger,
"Instantiating event receiving strategy with config "
void printContents(std::ostream &stream) const
A class responsible of configuring the route that processes incoming events from one or more InConnec...
void setErrorStrategy(const ParticipantConfig::ErrorStrategy &strategy)
Sets the desired error strategy to use.
const ParticipantConfig::EventProcessingStrategy & getReceivingStrategyConfig() const
void handlerAdded(rsb::HandlerPtr handler, const bool &wait)
Adds a new handler that will be notified about received events.
PushEventReceivingStrategyPtr eventReceivingStrategy
EventReceivingStrategyFactory & getEventReceivingStrategyFactory()
std::string getName() const
Returns the name of the implementation to be selected.
virtual void handle(EventPtr event)=0
Dispatches the event to the listener.
virtual ~PushInRouteConfigurator()
rsc::runtime::Properties getOptions() const
Returns the options for the strategy.
boost::shared_ptr< Handler > HandlerPtr
ConnectorSet getConnectors()
void printContents(std::ostream &stream) const
std::set< transport::InConnectorPtr > ConnectorSet
EventReceivingStrategyPtr createEventReceivingStrategy()
void handlerRemoved(rsb::HandlerPtr handler, const bool &wait)
Removes a previously registered handle.
boost::shared_ptr< EventReceivingStrategy > EventReceivingStrategyPtr
A utility class to simplify event handling in ordinary functions or member functions.
boost::shared_ptr< Handler > HandlerPtr
ErrorStrategy
Possible error handling strategies in user-provided code like event handlers.
boost::shared_ptr< InPushConnector > InPushConnectorPtr
EventReceivingStrategyPtr getEventReceivingStrategy() const
A class describing the configuration of Participant instances.
rsc::logging::LoggerPtr logger
ParticipantConfig::ErrorStrategy errorStrategy
Objects of classes which implement this specialized InConnector interface provide the ability to rece...
std::string getClassName() const
Scope is a descriptor for a hierarchical channel of the unified bus.
This class serves as a base class for event receiving strategy classes that deliver rsb::Event s to r...