47 Listener::Listener(
const vector<InPushConnectorPtr>& connectors,
51 d->logger = rsc::logging::Logger::getLogger(
"rsb.Listener");
63 return d->configurator->getTransportURLs();
68 d->configurator.reset(
70 d->configurator->setErrorStrategy(
getConfig().getErrorStrategy());
71 for (vector<InPushConnectorPtr>::const_iterator it = connectors.begin(); it
72 != connectors.end(); ++it) {
73 d->configurator->addConnector(*it);
78 d->configurator->activate();
82 d->configurator->handlerAdded(h, wait);
86 d->configurator->handlerRemoved(h, wait);
90 d->configurator->filterAdded(filter);
94 d->configurator->filterRemoved(filter);
boost::shared_ptr< PushInRouteConfigurator > PushInRouteConfiguratorPtr
Objects of this class participate in the exchange of notifications on one channel of the bus...
void removeHandler(HandlerPtr h, bool wait=true)
Removes a Handler instance to process newly received events.
boost::shared_ptr< Filter > FilterPtr
void removeFilter(filter::FilterPtr filter)
Removes a previously installed filter if it is present by pointer comparison some time after this cal...
ParticipantConfig getConfig() const
Returns a copy of the participant's configuration.
virtual void addHandler(HandlerPtr h, bool wait=true)
Adds a rsb::Handler to the Listener.
boost::scoped_ptr< Impl > d
virtual const std::set< std::string > getTransportURLs() const
TODO.
virtual std::string getKind() const
Return the kind of the participant.
boost::shared_ptr< Handler > HandlerPtr
This specialization of InRouteConfigurator creates and maintains an event receiving setup in which rs...
QualityOfServiceSpec getQualityOfServiceSpec() const
Returns the current settings for QoS.
rsc::logging::LoggerPtr logger
A class describing the configuration of Participant instances.
Scope is a descriptor for a hierarchical channel of the unified bus.
void addFilter(filter::FilterPtr filter)
Adds a filter that will be applied after some time (but not immediately after this call) for all hand...
void initialize(const std::vector< transport::InPushConnectorPtr > &connectors, const Scope &scope, const ParticipantConfig &config)
eventprocessing::PushInRouteConfiguratorPtr configurator