|
FRODO Version 2.19.1
An open-source framework for Distributed Constraint Optimization (DCOP)
|
This pipe stores the messages passed to it using pushObject(). More...

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< MessageWrapper > | messages = new LinkedList <MessageWrapper> () |
| The messages received. | |
This pipe stores the messages passed to it using pushObject().
| void frodo2.communication.QueueTest.QueueOutputPipeTrivial.close | ( | ) |
Does nothing.
Implements frodo2.communication.QueueOutputPipeInterface.
| MessageWrapper frodo2.communication.QueueTest.QueueOutputPipeTrivial.getNextMsg | ( | ) |
Returns the next message received, or null if there is none.
References messages.
Referenced by getNextMsgTimed().
| MessageWrapper frodo2.communication.QueueTest.QueueOutputPipeTrivial.getNextMsgTimed | ( | ) |
Waits until there is a message in the list and returns it, or times out.
References getNextMsg().
Referenced by frodo2.communication.QueueTest.testSendToMultiple().

| void frodo2.communication.QueueTest.QueueOutputPipeTrivial.pushMessage | ( | MessageWrapper | msgWrap | ) |
| String frodo2.communication.QueueTest.QueueOutputPipeTrivial.toDOT | ( | ) |
|
private |
The messages received.
Referenced by getNextMsg(), and pushMessage().