RSB  0.7.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
rsb::eventprocessing::PushInRouteConfigurator Class Reference

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:
Inheritance graph
Collaboration diagram for rsb::eventprocessing::PushInRouteConfigurator:
Collaboration graph

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
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
handlerthe handler to add
waitif 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
handlerhandler to remove
waitif 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
strategythe strategy to use

Definition at line 98 of file PushInRouteConfigurator.cpp.

References errorStrategy, and eventReceivingStrategy.

Member Data Documentation

ParticipantConfig::ErrorStrategy rsb::eventprocessing::PushInRouteConfigurator::errorStrategy
private

Definition at line 90 of file PushInRouteConfigurator.h.

Referenced by activate(), printContents(), and setErrorStrategy().

PushEventReceivingStrategyPtr rsb::eventprocessing::PushInRouteConfigurator::eventReceivingStrategy
private

Definition at line 91 of file PushInRouteConfigurator.h.

Referenced by activate(), handlerAdded(), handlerRemoved(), and setErrorStrategy().

rsc::logging::LoggerPtr rsb::eventprocessing::PushInRouteConfigurator::logger
private

Definition at line 88 of file PushInRouteConfigurator.h.

Referenced by createEventReceivingStrategy().


The documentation for this class was generated from the following files: