frodo2.communication.tcp.QueueInputPipeTCPTest.Sender Class Reference

A client that connects to the queue and to send serialized messages through TCP. More...

Inheritance diagram for frodo2.communication.tcp.QueueInputPipeTCPTest.Sender:

Public Member Functions
	Sender (Message message)
	Constructor.
	Sender (List< Message > messages)
	Constructor.
void	start ()
void	run ()
	Connects to the pipe and sends messages to it.

Private Attributes
final LinkedList< Message >	messages = new LinkedList <Message> ()
	Messages to be sent to the queue.

Detailed Description

A client that connects to the queue and to send serialized messages through TCP.

Constructor & Destructor Documentation

Sender() [1/2]

frodo2.communication.tcp.QueueInputPipeTCPTest.Sender.Sender

(

Message

message

)

Constructor.

Parameters

message

message to be sent to the queue

References start().

Here is the call graph for this function:

Sender() [2/2]

frodo2.communication.tcp.QueueInputPipeTCPTest.Sender.Sender

(

List< Message >

messages

)

Constructor.

Parameters

messages

messages to be sent to the queue

References messages, and start().

Here is the call graph for this function:

Member Function Documentation

run()

void frodo2.communication.tcp.QueueInputPipeTCPTest.Sender.run

(

)

Connects to the pipe and sends messages to it.

Bug

socket and out will not be closed

References messages, and frodo2.communication.tcp.QueueInputPipeTCPTest.QueueInputPipeTCPTest().

Here is the call graph for this function:

start()

void frodo2.communication.tcp.QueueInputPipeTCPTest.Sender.start

(

)

See also

java.lang.Thread#start()

Referenced by Sender(), and Sender().

Member Data Documentation

messages

final LinkedList<Message> frodo2.communication.tcp.QueueInputPipeTCPTest.Sender.messages = new LinkedList <Message> ()

private

Messages to be sent to the queue.

Referenced by run(), and Sender().

---

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

• src/frodo2/communication/tcp/QueueInputPipeTCPTest.java