Input-output pipe between two queues. More...

Inheritance diagram for frodo2.communication.sharedMemory.QueueIOPipe:

[legend]

Public Member Functions
	QueueIOPipe (Queue queue)
	Constructor.
	QueueIOPipe (Queue queue, boolean virtual)
	Constructor.
void	pushMessage (MessageWrapper msg)
	Passes a message to this pipe's queue.
void	close ()
	Does nothing.
String	toDOT ()

Private Attributes
Queue	queue
	This input pipe's queue.
final boolean	virtual
	Whether this pipe is between an agent and itself.

Static Private Attributes
static final long	serialVersionUID = -4232985879625166953L
	Used for serialization.

Detailed Description

Input-output pipe between two queues.

Author: Thomas Leaute

Constructor & Destructor Documentation

◆ QueueIOPipe() [1/2]

frodo2.communication.sharedMemory.QueueIOPipe.QueueIOPipe ( Queue queue )

Constructor.

Notifies the queue.

Parameters

queue the queue to which messages should be passed

References queue.

◆ QueueIOPipe() [2/2]

frodo2.communication.sharedMemory.QueueIOPipe.QueueIOPipe	(	Queue	queue,
		boolean	virtual )

Constructor.

Notifies the queue.

Parameters

queue	the queue to which messages should be passed
virtual	whether this pipe is between an agent and itself

References queue, and virtual.

Member Function Documentation

◆ close()

void frodo2.communication.sharedMemory.QueueIOPipe.close ( )

Does nothing.

See also: frodo2.communication.QueueInputPipeInterface.close()

Implements frodo2.communication.QueueInputPipeInterface.

◆ pushMessage()

void frodo2.communication.sharedMemory.QueueIOPipe.pushMessage ( MessageWrapper msg )

Passes a message to this pipe's queue.

See also: frodo2.communication.QueueOutputPipeInterface.pushMessage(frodo2.communication.MessageWrapper)

Implements frodo2.communication.QueueOutputPipeInterface.

References frodo2.communication.Message.fakeSerialize(), frodo2.communication.MessageWrapper.getMessage(), and queue.

Referenced by frodo2.communication.mailer.tests.testCentralMailer.testNext().

Here is the call graph for this function:

◆ toDOT()

String frodo2.communication.sharedMemory.QueueIOPipe.toDOT ( )

See also: frodo2.communication.QueueInputPipeInterface.toDOT()

Implements frodo2.communication.QueueInputPipeInterface.

Member Data Documentation

◆ queue

Queue frodo2.communication.sharedMemory.QueueIOPipe.queue

private

This input pipe's queue.

Referenced by pushMessage(), QueueIOPipe(), and QueueIOPipe().

◆ serialVersionUID

final long frodo2.communication.sharedMemory.QueueIOPipe.serialVersionUID = -4232985879625166953L

staticprivate

Used for serialization.

◆ virtual

final boolean frodo2.communication.sharedMemory.QueueIOPipe.virtual

private

Whether this pipe is between an agent and itself.

Referenced by QueueIOPipe().

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

src/frodo2/communication/sharedMemory/QueueIOPipe.java

Public Member Functions

Private Attributes

Static Private Attributes