This specialization of InRouteConfigurator creates and maintains an event receiving setup in which rsb::Event s are delivered using a push-style data flow by invoking registered rsb::Handler s. More...

#include <PushInRouteConfigurator.h>

Inheritance diagram for rsb::eventprocessing::PushInRouteConfigurator:

Collaboration diagram for rsb::eventprocessing::PushInRouteConfigurator:

Public Member Functions
	PushInRouteConfigurator (const Scope &scope, const ParticipantConfig &config)
virtual	~PushInRouteConfigurator ()
std::string	getClassName () const
void	printContents (std::ostream &stream) const
void	handlerAdded (rsb::HandlerPtr handler, const bool &wait)
	Adds a new handler that will be notified about received events.
void	handlerRemoved (rsb::HandlerPtr handler, const bool &wait)
	Removes a previously registered handle.
void	setErrorStrategy (const ParticipantConfig::ErrorStrategy &strategy)
	Sets the desired error strategy to use.
void	activate ()
Public Member Functions inherited from rsb::eventprocessing::InRouteConfigurator
	InRouteConfigurator (const Scope &scope, const ParticipantConfig &config)
virtual	~InRouteConfigurator ()
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
EventReceivingStrategyPtr	createEventReceivingStrategy ()

Private Attributes
rsc::logging::LoggerPtr	logger
ParticipantConfig::ErrorStrategy	errorStrategy
PushEventReceivingStrategyPtr	eventReceivingStrategy

Additional Inherited Members
Public Types inherited from rsb::eventprocessing::InRouteConfigurator
typedef std::set < transport::InConnectorPtr >	ConnectorSet

Detailed Description

This specialization of InRouteConfigurator creates and maintains an event receiving setup in which rsb::Event s are delivered using a push-style data flow by invoking registered rsb::Handler s.

Author: jmoringe

Definition at line 49 of file PushInRouteConfigurator.h.

Constructor & Destructor Documentation

rsb::eventprocessing::PushInRouteConfigurator::PushInRouteConfigurator	(	const Scope &	scope,
		const ParticipantConfig &	config
	)

Definition at line 45 of file PushInRouteConfigurator.cpp.

rsb::eventprocessing::PushInRouteConfigurator::~PushInRouteConfigurator ( )

virtual

Definition at line 52 of file PushInRouteConfigurator.cpp.

Member Function Documentation

void rsb::eventprocessing::PushInRouteConfigurator::activate ( )

virtual

Reimplemented from rsb::eventprocessing::InRouteConfigurator.

Definition at line 64 of file PushInRouteConfigurator.cpp.

References errorStrategy, eventReceivingStrategy, rsb::eventprocessing::InRouteConfigurator::getConnectors(), rsb::eventprocessing::InRouteConfigurator::getEventReceivingStrategy(), and rsb::eventprocessing::EventReceivingStrategy::handle().

Here is the call graph for this function:

EventReceivingStrategyPtr rsb::eventprocessing::PushInRouteConfigurator::createEventReceivingStrategy ( )

private

Definition at line 105 of file PushInRouteConfigurator.cpp.

References rsb::eventprocessing::getEventReceivingStrategyFactory(), rsb::ParticipantConfig::EventProcessingStrategy::getName(), rsb::ParticipantConfig::EventProcessingStrategy::getOptions(), rsb::eventprocessing::InRouteConfigurator::getReceivingStrategyConfig(), and logger.

Here is the call graph for this function:

string rsb::eventprocessing::PushInRouteConfigurator::getClassName ( ) const

Reimplemented from rsb::eventprocessing::InRouteConfigurator.

Definition at line 55 of file PushInRouteConfigurator.cpp.

void rsb::eventprocessing::PushInRouteConfigurator::handlerAdded	(	rsb::HandlerPtr	handler,
		const bool &	wait
	)

Adds a new handler that will be notified about received events.

Parameters

handler	the handler to add
wait	if set to `true`, this call will return only after the handler has been completely installed and will receive the next available event

Definition at line 90 of file PushInRouteConfigurator.cpp.

References eventReceivingStrategy.

void rsb::eventprocessing::PushInRouteConfigurator::handlerRemoved	(	rsb::HandlerPtr	handler,
		const bool &	wait
	)

Removes a previously registered handle.

Parameters

handler	handler to remove
wait	if set to `true`, this call will return only after the handler has been completely removed and will not be notified anymore

Definition at line 94 of file PushInRouteConfigurator.cpp.

References eventReceivingStrategy.

void rsb::eventprocessing::PushInRouteConfigurator::printContents ( std::ostream & stream ) const

Reimplemented from rsb::eventprocessing::InRouteConfigurator.

Definition at line 59 of file PushInRouteConfigurator.cpp.

References errorStrategy.

void rsb::eventprocessing::PushInRouteConfigurator::setErrorStrategy ( const ParticipantConfig::ErrorStrategy & strategy )

Sets the desired error strategy to use.

Parameters

strategy the strategy to use

Definition at line 98 of file PushInRouteConfigurator.cpp.

References errorStrategy, and eventReceivingStrategy.