org.d_haven.event.impl

Class MultiCastSink.MultiCastPreparedEnqueue

java.lang.Object

org.d_haven.event.impl.MultiCastSink.MultiCastPreparedEnqueue

All Implemented Interfaces:

PreparedEnqueue

Enclosing class:

MultiCastSink

private static final class MultiCastSink.MultiCastPreparedEnqueue
extends java.lang.Object
implements PreparedEnqueue

A prepared enqueue object that holds other prepared enqueue objects and allows to perform a commit / abort on all of these objects.

Since:

May 16, 2002

Author:

schierma

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Collection	m_preparedEnqueues

Constructor Summary

Constructors

Modifier	Constructor and Description
private	MultiCastSink.MultiCastPreparedEnqueue()

Method Summary

Methods

Modifier and Type	Method and Description
void	abort() Abort a previously prepared provisional enqueue operation (from the prepareEnqueue method).
void	addPreparedEnqueue(PreparedEnqueue preparedEnqueue) Adds a prepared enqueue object to the list of prepared enqueues.
void	commit() Commit a previously prepared provisional enqueue operation (from the prepareEnqueue method).
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

m_preparedEnqueues

private final java.util.Collection m_preparedEnqueues

Constructor Detail

MultiCastSink.MultiCastPreparedEnqueue

private MultiCastSink.MultiCastPreparedEnqueue()

Method Detail

abort

public void abort()

Description copied from interface: PreparedEnqueue

Abort a previously prepared provisional enqueue operation (from the prepareEnqueue method). Causes the queue to discard the provisionally enqueued elements.

Specified by:

abort in interface PreparedEnqueue

commit

public void commit()

Description copied from interface: PreparedEnqueue

Commit a previously prepared provisional enqueue operation (from the prepareEnqueue method). Causes the provisionally enqueued elements to appear on the queue for future dequeue operations. Note that once a prepareEnqueue has returned an enqueue key, the queue cannot reject the entries.

Specified by:

commit in interface PreparedEnqueue

addPreparedEnqueue

public void addPreparedEnqueue(PreparedEnqueue preparedEnqueue)

Adds a prepared enqueue object to the list of prepared enqueues.

Parameters:

preparedEnqueue - The prepared enqueue object to be added.

Since:

May 16, 2002

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object