OSM_AG_MsgManager Class Reference

Receives, validates message events from agents and send them to master. More...

#include <osm_ag_msgmanager.h>

Collaboration diagram for OSM_AG_MsgManager:

[legend]List of all members.

Public Member Functions
int	init (int argc, ACE_TCHAR *argv[])
	Make initial task to run the MSG_Manager Service within Osmius agent.
int	fini ()
	Perform the final task to end the MSG_Manager Service.
int	put (ACE_Message_Block *mblk, ACE_Time_Value *tm=0)
	Just pass the call to Msg_Sender put().
OSM_AG_MsgSender *	msg_sender (void)
	Return a pointer to the local MSG_Sender.
Static Public Member Functions
static OSM_AG_MsgManager *	instance (void)
	Returns singleton.
Protected Attributes
OSM_AG_MsgConnector	connector_
	Factory that actively connects the OSM_AG_MsgSender.
OSM_AG_MsgSender	msg_sender_
	The OSM_AG_MsgSender connected by OSM_AG_MsgConnector.

---

Detailed Description

Receives, validates message events from agents and send them to master.

With this service we receive messages from events via our put() method. We store those messages into a Message Queue so the code to execute those events don't need to wait too much time and could continue doing their job. We send the messages in the queue to the master in bulk clusters of messages to improve performance using several threads (This could be with a configurable parameter). To do this we use a Connector using a message sender class. Implements a singleton.

Definition at line 291 of file osm_ag_msgmanager.h.

---

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

• ag/osm_ag_msgmanager.h
• ag/osm_ag_msgmanager.cpp

---