RapidEventCollector Class Reference

Event Collector class. More...

Collaboration diagram for RapidEventCollector:

List of all members.

Public Member Functions
void	registerForMessages (Agent srcAgent, MessageType type, IRapidEventListener listener) throws RapidEventCollectorException
void	registerForMessages (Agent[] srcAgents, MessageType type, IRapidEventListener listener) throws RapidEventCollectorException
void	registerForMessages (Agent srcAgent, MessageType[] types, IRapidEventListener listener) throws RapidEventCollectorException
void	registerForMessages (MessageType[] types, IRapidEventListener listener) throws RapidEventCollectorException
	Register for messages from all known Agent partitions.
void	registerForMessages (MessageType type, IRapidEventListener listener) throws RapidEventCollectorException
	Register for messages from all known Agent partitions.
void	registerForMessages (Agent[] srcAgents, MessageType[] types, IRapidEventListener listener) throws RapidEventCollectorException
void	unsubscribeForMessages (Agent agent, MessageType type, IRapidEventListener l) throws RapidEventCollectorException
void	unsubscribeForMessages (Agent[] srcAgents, MessageType[] types, IRapidEventListener listener) throws RapidEventCollectorException
void	unsubscribeForMessages (MessageType type, IRapidEventListener listener) throws RapidEventCollectorException
Static Public Member Functions
static RapidEventCollector	getInstance ()
static void	registerForMessagesAtDDSPipe (Agent srcAgent, MessageType type, DataReaderListener dataReaderListener) throws RapidEventCollectorException
	Give the ability for message to directly register with DDS figure out some way for IRapidEventListener to have DDS registration component.
static void	registerForMessagesAtDDSPipe (Agent[] srcAgents, MessageType type, DataReaderListener dataReaderListener) throws RapidEventCollectorException
Protected Member Functions
AgentEventCollector	getAgentEventCollector (Agent agent)
Protected Attributes
final HashMap< Agent, AgentEventCollector >	m_collectors = new HashMap<Agent,AgentEventCollector>()

---

Detailed Description

Provides a hash map of RapidEventCollector instances which are associated with Agent types.

The RapidEventCollector will take RapidEventListener objects and will be the interface between Rapid and DDS.

---

Member Function Documentation

AgentEventCollector getAgentEventCollector

(

Agent

agent

)

[protected]

static RapidEventCollector getInstance

(

)

[static]

void registerForMessages	(	Agent[]	srcAgents,
		MessageType	type,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Parameters:

srcAgents
type
listener

Exceptions:

RapidEventCollectorException

Here is the call graph for this function:

void registerForMessages	(	Agent[]	srcAgents,
		MessageType[]	types,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Parameters:

srcAgents
types
listener

Exceptions:

Exception

Here is the call graph for this function:

void registerForMessages	(	Agent	srcAgent,
		MessageType[]	types,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Parameters:

srcAgent
types
listener

Exceptions:

RapidEventCollectorException

Here is the call graph for this function:

void registerForMessages	(	Agent	srcAgent,
		MessageType	type,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Parameters:

srcAgent
type
listener

Exceptions:

RapidEventCollectorException

void registerForMessages	(	MessageType[]	types,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Here is the call graph for this function:

void registerForMessages	(	MessageType	type,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Here is the call graph for this function:

static void registerForMessagesAtDDSPipe	(	Agent	srcAgent,
		MessageType	type,
		DataReaderListener	dataReaderListener
	)		throws RapidEventCollectorException [static]

if this works better, just refactor name to registerForMessages( )

Parameters:

srcAgent
type
dataReaderListener

Exceptions:

Exception

static void registerForMessagesAtDDSPipe	(	Agent[]	srcAgents,
		MessageType	type,
		DataReaderListener	dataReaderListener
	)		throws RapidEventCollectorException [static]

Here is the call graph for this function:

void unsubscribeForMessages	(	Agent	agent,
		MessageType	type,
		IRapidEventListener	l
	)		throws RapidEventCollectorException

void unsubscribeForMessages	(	Agent[]	srcAgents,
		MessageType[]	types,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Here is the call graph for this function:

void unsubscribeForMessages	(	MessageType	type,
		IRapidEventListener	listener
	)		throws RapidEventCollectorException

Here is the call graph for this function:

---

Member Data Documentation

final HashMap<Agent,AgentEventCollector> m_collectors = new HashMap<Agent,AgentEventCollector>() [protected]

---

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

• RapidEventCollector.java