rsb::spread::OutConnector Class Reference

#include <OutConnector.h>

Inheritance diagram for rsb::spread::OutConnector:

Collaboration diagram for rsb::spread::OutConnector:

Public Member Functions
	OutConnector (ConverterSelectionStrategyPtr converters, const std::string &host=defaultHost(), unsigned int port=defaultPort(), unsigned int maxFragmentSize=100000)
virtual	~OutConnector ()
std::string	getClassName () const
void	printContents (std::ostream &stream) const
void	handle (rsb::EventPtr e)
	Handle event.
void	activate ()
	Activates the connector.
void	deactivate ()
void	setQualityOfServiceSpecs (const QualityOfServiceSpec &specs)
	Requests new QoS settings for publishing events.

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

Private Attributes
rsc::logging::LoggerPtr	logger
bool	active
SpreadConnectorPtr	connector
unsigned int	maxFragmentSize
unsigned int	minDataSpace
	The number of bytes minimally required to successfully serialize the notification with the limited size for each fragment.

Additional Inherited Members
Public Types inherited from rsb::transport::OutConnector
typedef boost::shared_ptr < OutConnector >	Ptr
Public Types inherited from rsb::transport::ConverterSelectingConnector< std::string >
typedef converter::Converter < std::string >::Ptr	ConverterPtr
typedef converter::ConverterSelectionStrategy < std::string >::Ptr	ConverterSelectionStrategyPtr
Protected Member Functions inherited from rsb::transport::ConverterSelectingConnector< std::string >
	ConverterSelectingConnector (ConverterSelectionStrategyPtr converters)
ConverterPtr	getConverter (const std::string &key) const
	Try to find a suitable converter for key .

Detailed Description

Author

jmoringe

Definition at line 44 of file OutConnector.h.

Constructor & Destructor Documentation

rsb::spread::OutConnector::OutConnector	(	ConverterSelectionStrategyPtr	converters,
		const std::string &	host = defaultHost(),
		unsigned int	port = defaultPort(),
		unsigned int	maxFragmentSize = 100000
	)

Definition at line 61 of file OutConnector.cpp.

rsb::spread::OutConnector::~OutConnector ( )

virtual

Reimplemented from rsb::transport::OutConnector.

Definition at line 69 of file OutConnector.cpp.

References active, and deactivate().

Here is the call graph for this function:

Member Function Documentation

void rsb::spread::OutConnector::activate ( )

virtual

Activates the connector.

Settings made between construction and activation via this method must be applied on a call to this method.

Implements rsb::transport::Connector.

Definition at line 83 of file OutConnector.cpp.

References active, and connector.

static rsb::transport::OutConnector* rsb::spread::OutConnector::create ( const rsc::runtime::Properties &  args )

static

void rsb::spread::OutConnector::deactivate ( )

virtual

Implements rsb::transport::Connector.

Definition at line 88 of file OutConnector.cpp.

References active, and connector.

Referenced by ~OutConnector().

Here is the caller graph for this function:

string rsb::spread::OutConnector::getClassName

(

)

const

Definition at line 75 of file OutConnector.cpp.

void rsb::spread::OutConnector::handle ( rsb::EventPtr  event )

virtual

Handle event.

Parameters

event

The event that should be handled.

Implements rsb::eventprocessing::Handler.

Definition at line 97 of file OutConnector.cpp.

References rsb::spread::SpreadMessage::addGroup(), connector, rsb::protocol::fillNotificationHeader(), rsb::protocol::fillNotificationId(), rsb::transport::ConverterSelectingConnector< std::string >::getConverter(), rsb::spread::SpreadMessage::getSize(), maxFragmentSize, minDataSpace, and rsb::spread::SpreadMessage::setQOS().

Here is the call graph for this function:

void rsb::spread::OutConnector::printContents

(

std::ostream &

stream

)

const

Definition at line 79 of file OutConnector.cpp.

References active, and connector.

void rsb::spread::OutConnector::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 93 of file OutConnector.cpp.

References connector.

Member Data Documentation

bool rsb::spread::OutConnector::active

private

Definition at line 67 of file OutConnector.h.

Referenced by activate(), deactivate(), printContents(), and ~OutConnector().

SpreadConnectorPtr rsb::spread::OutConnector::connector

private

Definition at line 68 of file OutConnector.h.

Referenced by activate(), deactivate(), handle(), printContents(), and setQualityOfServiceSpecs().

rsc::logging::LoggerPtr rsb::spread::OutConnector::logger

private

Definition at line 66 of file OutConnector.h.

unsigned int rsb::spread::OutConnector::maxFragmentSize

private

Definition at line 69 of file OutConnector.h.

Referenced by handle().

unsigned int rsb::spread::OutConnector::minDataSpace

private

The number of bytes minimally required to successfully serialize the notification with the limited size for each fragment.

Definition at line 74 of file OutConnector.h.

Referenced by handle().

---

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

• rsb/transport/spread/OutConnector.h
• rsb/transport/spread/OutConnector.cpp