org.d_haven.event.impl
Class DefaultPipe.DefaultPreparedEnqueue
java.lang.Object
org.d_haven.event.impl.DefaultPipe.DefaultPreparedEnqueue
- All Implemented Interfaces:
- PreparedEnqueue
- Enclosing class:
- DefaultPipe
private static final class DefaultPipe.DefaultPreparedEnqueue
- extends java.lang.Object
- implements PreparedEnqueue
Method Summary |
void |
abort()
Abort a previously prepared provisional enqueue operation (from
the prepareEnqueue method). |
private void |
checkAlreadyProcessed()
|
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 |
m_parent
private final DefaultPipe m_parent
m_elems
private java.lang.Object[] m_elems
DefaultPipe.DefaultPreparedEnqueue
private DefaultPipe.DefaultPreparedEnqueue(DefaultPipe parent,
java.lang.Object[] elements)
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
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
checkAlreadyProcessed
private void checkAlreadyProcessed()
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object