org.rvpf.som.queue

Class MemoryQueue

Object

Queue.Abstract

MemoryQueue

public final class MemoryQueue
extends Queue.Abstract

Memory queue.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Queue.Abstract Abstract queue.

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEEP_LIMIT_PROPERTY Keep limit property.
static String	RECEIVER_REQUIRED_PROPERTY Receiver required property.

Fields inherited from class Queue.Abstract

AUTOCOMMIT_PROPERTY, AUTOCOMMIT_THRESHOLD_PROPERTY, AUTOCOMMIT_TIMEOUT_PROPERTY

Method Summary

Modifier and Type	Method and Description
QueueInfo	getInfo()
MemoryQueue.Receiver	newReceiver()
MemoryQueue.Sender	newSender()
protected void	onReceiverClosed(Queue.Receiver receiver) Called when the receiver is closed.
boolean	setUp(KeyedValues somProperties) Sets up this queue.
void	tearDown() Tears down what has been set up.

Methods inherited from class Queue.Abstract

getAutocommitThreshold, getName, getStats, getThisLogger, getTimeoutMonitor, hasReceiver, isAutocommit, onNewReceiver, onNewSender, onSenderClosed

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KEEP_LIMIT_PROPERTY

public static final String KEEP_LIMIT_PROPERTY

Keep limit property.

See Also:

Constant Field Values

RECEIVER_REQUIRED_PROPERTY

public static final String RECEIVER_REQUIRED_PROPERTY

Receiver required property.

See Also:

Constant Field Values

Method Detail

getInfo

public QueueInfo getInfo()

newReceiver

public MemoryQueue.Receiver newReceiver()

newSender

public MemoryQueue.Sender newSender()

setUp

public boolean setUp(KeyedValues somProperties)

Sets up this queue.

Overrides:

setUp in class Queue.Abstract

Parameters:

somProperties - The SOM properties.

Returns:

True on success.

tearDown

public void tearDown()

Tears down what has been set up.

Overrides:

tearDown in class Queue.Abstract

onReceiverClosed

protected void onReceiverClosed(Queue.Receiver receiver)

Called when the receiver is closed.

Overrides:

onReceiverClosed in class Queue.Abstract

Parameters:

receiver - The receiver.