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. More...

void	handlerRemoved (rsb::HandlerPtr handler, const bool &wait)
	Removes a previously registered handle. More...

void	setErrorStrategy (const ParticipantConfig::ErrorStrategy &strategy)
	Sets the desired error strategy to use. More...

void	activate ()

Public Member Functions inherited from rsb::eventprocessing::InRouteConfigurator
	InRouteConfigurator (const Scope &scope, const ParticipantConfig &config)

virtual	~InRouteConfigurator ()

std::string	getClassName () const

void	printContents (std::ostream &stream) const

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
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 rsb::eventprocessing::InRouteConfigurator::activate(), 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 ( )

privatevirtual

Implements rsb::eventprocessing::InRouteConfigurator.

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

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

Definition at line 59 of file PushInRouteConfigurator.cpp.

References errorStrategy, and rsb::eventprocessing::InRouteConfigurator::printContents().

Here is the call graph for this function: