FRODO Version 2.19.1
An open-source framework for Distributed Constraint Optimization (DCOP)
Loading...
Searching...
No Matches
frodo2.communication.QueueTest.QueueOutputPipeTrivial Class Reference

This pipe stores the messages passed to it using pushObject(). More...

Inheritance diagram for frodo2.communication.QueueTest.QueueOutputPipeTrivial:

Public Member Functions

void pushMessage (MessageWrapper msgWrap)
MessageWrapper getNextMsg ()
 Returns the next message received, or null if there is none.
MessageWrapper getNextMsgTimed ()
 Waits until there is a message in the list and returns it, or times out.
void close ()
 Does nothing.
String toDOT ()

Private Attributes

LinkedList< MessageWrappermessages = new LinkedList <MessageWrapper> ()
 The messages received.

Detailed Description

This pipe stores the messages passed to it using pushObject().

Author
Thomas Leaute

Member Function Documentation

◆ close()

void frodo2.communication.QueueTest.QueueOutputPipeTrivial.close ( )

◆ getNextMsg()

MessageWrapper frodo2.communication.QueueTest.QueueOutputPipeTrivial.getNextMsg ( )

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

Returns
the next message received

References messages.

Referenced by getNextMsgTimed().

◆ getNextMsgTimed()

MessageWrapper frodo2.communication.QueueTest.QueueOutputPipeTrivial.getNextMsgTimed ( )

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.QueueTest.testSendToMultiple().

Here is the call graph for this function:

◆ pushMessage()

void frodo2.communication.QueueTest.QueueOutputPipeTrivial.pushMessage ( MessageWrapper msgWrap)

◆ toDOT()

String frodo2.communication.QueueTest.QueueOutputPipeTrivial.toDOT ( )

Member Data Documentation

◆ messages

LinkedList<MessageWrapper> frodo2.communication.QueueTest.QueueOutputPipeTrivial.messages = new LinkedList <MessageWrapper> ()
private

The messages received.

Referenced by getNextMsg(), and pushMessage().


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