org.d_haven.event.impl
public class MultiCastSink extends Object implements Sink
Version: $Revision: 1.11 $
Nested Class Summary | |
---|---|
static class | MultiCastSink.MultiCastPreparedEnqueue
A prepared enqueue object that holds other prepared enqueue
objects and allows to perform a commit / abort on all of these
objects.
|
Field Summary | |
---|---|
boolean | m_single
Boolean value describing if one or all operations must succeed. |
Collection | m_sinks
A collection of sink arrays representing the sinks to enqueue
to. |
Constructor Summary | |
---|---|
MultiCastSink(Collection sinks)
This constructor creates a failure in-tolerant multicast sink
based on the collection of sink arrays. | |
MultiCastSink(Collection sinks, boolean single)
This constructor creates a failure in-tolerant multicast sink
based on the collection of sink arrays.
|
Method Summary | |
---|---|
void | enqueue(Object element) |
void | enqueue(Object[] elements) |
PreparedEnqueue | prepareEnqueue(Object[] elements) |
int | size() |
String | toString() |
boolean | tryEnqueue(Object element) |
Parameters: sinks A collection of sink arrays for each stage.
Since: May 16, 2002
Parameters: sinks A collection of sink arrays for each stage. single
Since: May 16, 2002