rsb::transport::InPushConnector Class Reference

Objects of classes which implement this specialized InConnector interface provide the ability to receive events in push-style manner by means of one transport mechanism. More...

#include <InPushConnector.h>

Inheritance diagram for rsb::transport::InPushConnector:

Collaboration diagram for rsb::transport::InPushConnector:

Public Types
typedef boost::shared_ptr< InPushConnector >	Ptr
Public Types inherited from rsb::transport::InConnector
typedef boost::shared_ptr< InConnector >	Ptr

Public Member Functions
virtual	~InPushConnector ()
virtual void	addHandler (eventprocessing::HandlerPtr handler)
virtual void	removeHandler (eventprocessing::HandlerPtr handler)
virtual void	setErrorStrategy (ParticipantConfig::ErrorStrategy strategy)
	A temporary hack to pass an ErrorStrategy to in push connectors so that they can be instructed by clients on what to do in case of asynchronous receive errors. More...
Public Member Functions inherited from rsb::transport::InConnector
virtual	~InConnector ()
Public Member Functions inherited from rsb::transport::Connector
virtual	~Connector ()
virtual void	setScope (const Scope &scope)=0
	Sets the scope this connector will send/receive events to/from. More...
virtual void	activate ()=0
	Activates the connector. More...
virtual void	deactivate ()=0
virtual void	setQualityOfServiceSpecs (const QualityOfServiceSpec &specs)=0
	Requests new QoS settings for publishing events. More...
virtual const std::string	getTransportURL () const =0
	Return an URL describing the transport kind and its configuration for this connector. More...
Public Member Functions inherited from rsb::filter::FilterObserver
	FilterObserver ()
virtual	~FilterObserver ()
virtual void	notify (Filter *filter, const FilterAction::Types &at)
virtual void	notify (ScopeFilter *filter, const FilterAction::Types &at)

Protected Types
typedef std::list< eventprocessing::HandlerPtr >	HandlerList

Protected Attributes
HandlerList	handlers

Detailed Description

Objects of classes which implement this specialized InConnector interface provide the ability to receive events in push-style manner by means of one transport mechanism.

Author

jmoringe

Definition at line 48 of file InPushConnector.h.

Member Typedef Documentation

typedef std::list<eventprocessing::HandlerPtr> rsb::transport::InPushConnector::HandlerList

protected

Definition at line 68 of file InPushConnector.h.

typedef boost::shared_ptr<InPushConnector> rsb::transport::InPushConnector::Ptr

Definition at line 50 of file InPushConnector.h.

Constructor & Destructor Documentation

rsb::transport::InPushConnector::~InPushConnector ( )

virtual

Reimplemented in rsb::transport::socket::InPushConnector, and rsb::transport::inprocess::InPushConnector.

Definition at line 34 of file InPushConnector.cpp.

Member Function Documentation

void rsb::transport::InPushConnector::addHandler ( eventprocessing::HandlerPtr  handler )

virtual

Definition at line 37 of file InPushConnector.cpp.

void rsb::transport::InPushConnector::removeHandler ( eventprocessing::HandlerPtr  handler )

virtual

Definition at line 41 of file InPushConnector.cpp.

void rsb::transport::InPushConnector::setErrorStrategy ( ParticipantConfig::ErrorStrategy  strategy )

virtual

A temporary hack to pass an ErrorStrategy to in push connectors so that they can be instructed by clients on what to do in case of asynchronous receive errors.

The current convention is that ERROR_STRATEGY_LOG and ERROR_STRATEGY_PRINT shall use the declared channel for displaying the error once and afterwards connectors should stop processing.

Parameters

strategy

the new error strategy to use

Definition at line 45 of file InPushConnector.cpp.

Member Data Documentation

HandlerList rsb::transport::InPushConnector::handlers

protected

Definition at line 70 of file InPushConnector.h.

Referenced by rsb::transport::inprocess::InPushConnector::handle(), and rsb::transport::socket::InPushConnector::handle().

---

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

• rsb/transport/InPushConnector.h
• rsb/transport/InPushConnector.cpp