frodo2.communication.sharedMemory.QueueIOPipeTest.Collector Class Reference

A listener that collects received messages. More...

Inheritance diagram for frodo2.communication.sharedMemory.QueueIOPipeTest.Collector:

Public Member Functions
void	notifyIn (Message msg)
Collection< MessageType >	getMsgTypes ()
void	setQueue (Queue queue)
Public Member Functions inherited from frodo2.communication.IncomingMsgPolicyInterface< T >
default void	notifyIn (Message msg, Object toAgent)
	Notifies the listener of an incoming message.

Private Member Functions
Message	getNextMsg ()
	Returns the next message received, or null if there is none.
Message	getNextMsgTimed ()
	Waits until there is a message in the list and returns it, or times out.

Private Attributes
LinkedList< Message >	messages = new LinkedList<Message> ()
	The messages received.

Detailed Description

A listener that collects received messages.

Member Function Documentation

getMsgTypes()

Collection< MessageType > frodo2.communication.sharedMemory.QueueIOPipeTest.Collector.getMsgTypes

(

)

See also

IncomingMsgPolicyInterface.getMsgTypes()

Implements frodo2.communication.MessageListener< T >.

References frodo2.communication.MessageType.ROOT.

getNextMsg()

Message frodo2.communication.sharedMemory.QueueIOPipeTest.Collector.getNextMsg ( )

private

Returns the next message received, or null if there is none.

Returns

the next message received

References messages.

Referenced by getNextMsgTimed().

getNextMsgTimed()

Message frodo2.communication.sharedMemory.QueueIOPipeTest.Collector.getNextMsgTimed ( )

private

Waits until there is a message in the list and returns it, or times out.

Returns

the next message received

References getNextMsg().

Referenced by frodo2.communication.sharedMemory.QueueIOPipeTest.test2QueuesInSeries(), frodo2.communication.sharedMemory.QueueIOPipeTest.test2QueuesInSeriesMultiple(), and frodo2.communication.sharedMemory.QueueIOPipeTest.test2QueuesInSeriesSerialized().

Here is the call graph for this function:

notifyIn()

void frodo2.communication.sharedMemory.QueueIOPipeTest.Collector.notifyIn

(

Message

msg

)

See also

IncomingMsgPolicyInterface.notifyIn(Message)

Implements frodo2.communication.IncomingMsgPolicyInterface< T >.

setQueue()

void frodo2.communication.sharedMemory.QueueIOPipeTest.Collector.setQueue

(

Queue

queue

)

See also

IncomingMsgPolicyInterface.setQueue(Queue)

Implements frodo2.communication.MessageListener< T >.

Member Data Documentation

messages

LinkedList<Message> frodo2.communication.sharedMemory.QueueIOPipeTest.Collector.messages = new LinkedList<Message> ()

private

The messages received.

Referenced by getNextMsg().

---

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

• src/frodo2/communication/sharedMemory/QueueIOPipeTest.java