rsb::transport::inprocess::InPushConnector Class Reference

#include <InPushConnector.h>

Inheritance diagram for rsb::transport::inprocess::InPushConnector:

Collaboration diagram for rsb::transport::inprocess::InPushConnector:

Public Member Functions
	InPushConnector ()
virtual	~InPushConnector ()
void	setQualityOfServiceSpecs (const QualityOfServiceSpec &specs)
	Requests new QoS settings for publishing events. More...
void	handle (EventPtr event)
	Handle event. More...
Public Member Functions inherited from rsb::transport::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::Connector
virtual	~Connector ()
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)
Public Member Functions inherited from rsb::transport::inprocess::InConnector
virtual	~InConnector ()
void	printContents (std::ostream &stream) const
virtual void	activate ()
	Activates the connector. More...
virtual void	deactivate ()
virtual Scope	getScope () const
virtual void	setScope (const Scope &scope)
	Sets the scope this connector will send/receive events to/from. More...
const std::string	getTransportURL () const
	Return an URL describing the transport kind and its configuration for this connector. More...
Public Member Functions inherited from rsb::eventprocessing::Handler
virtual	~Handler ()

Static Public Member Functions
static rsb::transport::InPushConnector *	create (const rsc::runtime::Properties &args)

Private Attributes
rsc::logging::LoggerPtr	logger

Additional Inherited Members
Public Types inherited from rsb::transport::InPushConnector
typedef boost::shared_ptr< InPushConnector >	Ptr
Public Types inherited from rsb::transport::InConnector
typedef boost::shared_ptr< InConnector >	Ptr
Protected Types inherited from rsb::transport::InPushConnector
typedef std::list< eventprocessing::HandlerPtr >	HandlerList
Protected Member Functions inherited from rsb::transport::inprocess::InConnector
	InConnector (BusPtr bus=getDefaultBus())
Protected Attributes inherited from rsb::transport::InPushConnector
HandlerList	handlers

Detailed Description

Author

jmoringe

Definition at line 47 of file InPushConnector.h.

Constructor & Destructor Documentation

rsb::transport::inprocess::InPushConnector::InPushConnector

(

)

Definition at line 41 of file InPushConnector.cpp.

References create().

Here is the call graph for this function:

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

virtual

Reimplemented from rsb::transport::InPushConnector.

Definition at line 54 of file InPushConnector.cpp.

Member Function Documentation

static rsb::transport::InPushConnector* rsb::transport::inprocess::InPushConnector::create ( const rsc::runtime::Properties &  args )

static

Referenced by InPushConnector().

Here is the caller graph for this function:

void rsb::transport::inprocess::InPushConnector::handle ( EventPtr  event )

virtual

Handle event.

Parameters

event

The event that should be handled.

TODO(jmoringe, 2011-11-07): This ensures not overwriting earlier receive timestamp added by different connector. However, thread-safety issue remains.

Implements rsb::eventprocessing::Handler.

Definition at line 60 of file InPushConnector.cpp.

References rsb::transport::InPushConnector::handlers.

void rsb::transport::inprocess::InPushConnector::setQualityOfServiceSpecs ( const QualityOfServiceSpec &  specs )

virtual

Requests new QoS settings for publishing events.

Does not influence the receiving part.

Parameters

specs

QoS specification

Exceptions

UnsupportedQualityOfServiceException

requirements cannot be met

Implements rsb::transport::Connector.

Definition at line 57 of file InPushConnector.cpp.

Member Data Documentation

rsc::logging::LoggerPtr rsb::transport::inprocess::InPushConnector::logger

private

Definition at line 60 of file InPushConnector.h.

---

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

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