org.apache.excalibur.event.impl
Class MultiCastSink
java.lang.Object
org.apache.excalibur.event.impl.MultiCastSink
- All Implemented Interfaces:
- org.apache.excalibur.event.Sink
public class MultiCastSink
- extends java.lang.Object
- implements org.apache.excalibur.event.Sink
This is a org.apache.excalibur.event.seda.event.Sink
implementation that multicasts enqueue operations to the
contained and concrete sink objects. The multi cast sink
will try to enqueue and only succeeds if no element was
rejected from any sink. The sink can be configured to
enqueue into one sink alone or all sinks.
If a sink array in the collection of sinks contains more
than one sink the multicast sink will try to enqueue the
element always to only one of these sinks.
- Version:
- $Revision: 1.4 $
- Author:
- Avalon Development Team
Fields inherited from interface org.apache.excalibur.event.Sink |
ROLE |
Constructor Summary |
MultiCastSink(java.util.Collection sinks)
This constructor creates a failure in-tolerant multicast
sink based on the collection of sink arrays. |
MultiCastSink(java.util.Collection sinks,
boolean single)
This constructor creates a failure in-tolerant multicast
sink based on the collection of sink arrays. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MultiCastSink
public MultiCastSink(java.util.Collection sinks)
- This constructor creates a failure in-tolerant multicast
sink based on the collection of sink arrays. The delivery
must succeed for all sinks in the collection or it will
fail entirely.
- Parameters:
sinks
- A collection of sink arrays for each stage.- Since:
- May 16, 2002
MultiCastSink
public MultiCastSink(java.util.Collection sinks,
boolean single)
- This constructor creates a failure in-tolerant multicast
sink based on the collection of sink arrays.
- Parameters:
sinks
- A collection of sink arrays for each stage.single
- true if just one operation must succeed.
false if all operations must succeed.- Since:
- May 16, 2002
canAccept
public int canAccept()
- Specified by:
canAccept
in interface org.apache.excalibur.event.Sink
- See Also:
Sink.canAccept()
isFull
public boolean isFull()
- Specified by:
isFull
in interface org.apache.excalibur.event.Sink
- See Also:
Sink.isFull()
maxSize
public int maxSize()
- Specified by:
maxSize
in interface org.apache.excalibur.event.Sink
- See Also:
Sink.maxSize()
enqueue
public void enqueue(java.lang.Object element)
throws org.apache.excalibur.event.SinkException
- Specified by:
enqueue
in interface org.apache.excalibur.event.Sink
- Throws:
org.apache.excalibur.event.SinkException
- See Also:
Sink.enqueue(Object)
enqueue
public void enqueue(java.lang.Object[] elements)
throws org.apache.excalibur.event.SinkException
- Specified by:
enqueue
in interface org.apache.excalibur.event.Sink
- Throws:
org.apache.excalibur.event.SinkException
- See Also:
Sink.enqueue(Object[])
tryEnqueue
public boolean tryEnqueue(java.lang.Object element)
- Specified by:
tryEnqueue
in interface org.apache.excalibur.event.Sink
- See Also:
Sink.tryEnqueue(Object)
prepareEnqueue
public org.apache.excalibur.event.PreparedEnqueue prepareEnqueue(java.lang.Object[] elements)
throws org.apache.excalibur.event.SinkException
- Specified by:
prepareEnqueue
in interface org.apache.excalibur.event.Sink
- Throws:
org.apache.excalibur.event.SinkException
- See Also:
Sink.prepareEnqueue(Object[])
size
public int size()
- Specified by:
size
in interface org.apache.excalibur.event.Sink
- See Also:
Sink.size()
Copyright © {inceptionYear}-2009 Apache Software Foundation. All Rights Reserved.