|
| |
|
| java.lang.Object
 java.lang.Thread
org.jgroups.stack.UpHandler
org.jgroups.protocols.QUEUE
| QUEUE | | public class QUEUE extends Protocol (Code) | | Queuing layer. Upon reception of event START_QUEUEING, all events traveling through
this layer upwards/downwards (depending on direction of event) will be queued. Upon
reception of a STOP_QUEUEING event, all events will be released. Finally, the
queueing flag is reset.
When queueing, only event STOP_QUEUEING (received up or downwards) will be allowed
to release queueing.
author:
Bela Ban |
| Inner Class :public interface Observer | |
| my_observer | | Observer my_observer(Code) | | |
| queueing_upqueueing_dn | | boolean queueing_upqueueing_dn(Code) | | |
| getName | | public String getName()(Code) | | All protocol names have to be unique !
|
| getQueueingDown | | public boolean getQueueingDown()(Code) | | |
| getQueueingUp | | public boolean getQueueingUp()(Code) | | |
| providedDownServices | | public Vector providedDownServices()(Code) | | |
| setObserver | | public void setObserver(Observer observer)(Code) | | Only 1 observer is allowed. More than one might slow down the system. Will be called
when an event is queued (up or down)
|
| up | | public void up(Event evt)(Code) | | Queues or passes up events. No queue sync. necessary, as this method is never called
concurrently.
|
| Fields inherited from org.jgroups.stack.UpHandler | final protected Log log(Code)(Java Doc)
|
|
|
|