rsb::spread::MessageHandler Class Reference

#include <MessageHandler.h>

Inheritance diagram for rsb::spread::MessageHandler:

Collaboration diagram for rsb::spread::MessageHandler:

Public Member Functions
	MessageHandler (ConverterSelectionStrategyPtr converters)
virtual	~MessageHandler ()
EventPtr	processMessage (SpreadMessagePtr message)
void	setPruning (const bool &pruning)

Private Member Functions
rsb::protocol::NotificationPtr	handleAndJoinFragmentedNotification (rsb::protocol::FragmentedNotificationPtr notification)

Private Attributes
rsc::logging::LoggerPtr	logger
AssemblyPoolPtr	assemblyPool

Additional Inherited Members
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 51 of file MessageHandler.h.

Constructor & Destructor Documentation

rsb::spread::MessageHandler::MessageHandler

(

ConverterSelectionStrategyPtr

converters

)

Definition at line 46 of file MessageHandler.cpp.

rsb::spread::MessageHandler::~MessageHandler ( )

virtual

Definition at line 52 of file MessageHandler.cpp.

Member Function Documentation

NotificationPtr rsb::spread::MessageHandler::handleAndJoinFragmentedNotification ( rsb::protocol::FragmentedNotificationPtr  notification )

private

Definition at line 96 of file MessageHandler.cpp.

References assemblyPool.

Referenced by processMessage().

Here is the caller graph for this function:

EventPtr rsb::spread::MessageHandler::processMessage

(

SpreadMessagePtr

message

)

Definition at line 55 of file MessageHandler.cpp.

References rsb::protocol::fillEvent(), rsb::transport::ConverterSelectingConnector< std::string >::getConverter(), handleAndJoinFragmentedNotification(), logger, and rsb::spread::SpreadMessage::REGULAR.

Referenced by rsb::spread::InPullConnector::raiseEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

void rsb::spread::MessageHandler::setPruning

(

const bool &

pruning

)

Definition at line 109 of file MessageHandler.cpp.

References assemblyPool.

Member Data Documentation

AssemblyPoolPtr rsb::spread::MessageHandler::assemblyPool

private

Definition at line 62 of file MessageHandler.h.

Referenced by handleAndJoinFragmentedNotification(), and setPruning().

rsc::logging::LoggerPtr rsb::spread::MessageHandler::logger

private

Definition at line 60 of file MessageHandler.h.

Referenced by processMessage().

---

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

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