RSB  0.9.6
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
rsb::transport::inprocess::InPushConnector Class Reference

#include <InPushConnector.h>

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

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)
 
- 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...
 
- 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 ()
 
- 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.

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
void rsb::transport::inprocess::InPushConnector::handle ( EventPtr  event)
virtual

Handle event.

Parameters
eventThe 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
specsQoS specification
Exceptions
UnsupportedQualityOfServiceExceptionrequirements 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: