frodo2.communication.QueueTest.QueueInputPipeTrivial Class Reference

This pipe has a list of messages ready to be pulled using pullMessage(). More...

Inheritance diagram for frodo2.communication.QueueTest.QueueInputPipeTrivial:

Public Member Functions
	QueueInputPipeTrivial (Queue queue)
	Constructor.
void	start ()
void	run ()
	Constantly passes messages to the queue.
void	addMessage (Message msg)
void	addMessage (MessageWrapper wrap)
	Adds a message wrapper.
void	close ()
	Terminates this pipe's thread.
String	toDOT ()

Private Attributes
LinkedList< MessageWrapper >	messages = new LinkedList <MessageWrapper> ()
	Messages waiting to be sent to the queue.
boolean	keepGoing = true
	Whether this pipe's thread should keep going or stop.
Queue	queue
	This pipe's queue.

Detailed Description

This pipe has a list of messages ready to be pulled using pullMessage().

Author

Thomas Leaute

Constructor & Destructor Documentation

QueueInputPipeTrivial()

frodo2.communication.QueueTest.QueueInputPipeTrivial.QueueInputPipeTrivial

(

Queue

queue

)

Constructor.

Parameters

queue

the queue messages should be passed to

References queue, and start().

Here is the call graph for this function:

Member Function Documentation

addMessage() [1/2]

void frodo2.communication.QueueTest.QueueInputPipeTrivial.addMessage

(

Message

msg

)

Parameters

msg	the message to set

References messages.

Referenced by frodo2.communication.QueueTest.testMultipleInputPipes().

addMessage() [2/2]

void frodo2.communication.QueueTest.QueueInputPipeTrivial.addMessage

(

MessageWrapper

wrap

)

Adds a message wrapper.

Parameters

wrap	message wrapper

References messages.

close()

void frodo2.communication.QueueTest.QueueInputPipeTrivial.close

(

)

Terminates this pipe's thread.

See also

QueueInputPipeInterface.close()

Implements frodo2.communication.QueueInputPipeInterface.

References keepGoing.

run()

void frodo2.communication.QueueTest.QueueInputPipeTrivial.run

(

)

Constantly passes messages to the queue.

See also

java.lang.Thread#run()

References keepGoing, messages, and queue.

start()

void frodo2.communication.QueueTest.QueueInputPipeTrivial.start

(

)

See also

java.lang.Thread#start()

Referenced by QueueInputPipeTrivial().

toDOT()

String frodo2.communication.QueueTest.QueueInputPipeTrivial.toDOT

(

)

See also

frodo2.communication.QueueInputPipeInterface.toDOT()

Implements frodo2.communication.QueueInputPipeInterface.

Member Data Documentation

keepGoing

boolean frodo2.communication.QueueTest.QueueInputPipeTrivial.keepGoing = true

private

Whether this pipe's thread should keep going or stop.

Referenced by close(), and run().

messages

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

private

Messages waiting to be sent to the queue.

Referenced by addMessage(), addMessage(), and run().

queue

Queue frodo2.communication.QueueTest.QueueInputPipeTrivial.queue

private

This pipe's queue.

Referenced by QueueInputPipeTrivial(), and run().

---

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

• src/frodo2/communication/QueueTest.java