org.jgroups.protocols

Class QUEUE

public class QUEUE extends Protocol

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

Nested Class Summary
interfaceQUEUE.Observer
Method Summary
voiddown(Event evt)
VectorgetDownVector()
StringgetName()
All protocol names have to be unique !
booleangetQueueingDown()
booleangetQueueingUp()
VectorgetUpVector()
VectorprovidedDownServices()
VectorprovidedUpServices()
voidsetObserver(QUEUE.Observer observer)
Only 1 observer is allowed.
voidup(Event evt)
Queues or passes up events.

Method Detail

down

public void down(Event evt)

getDownVector

public Vector getDownVector()

getName

public String getName()
All protocol names have to be unique !

getQueueingDown

public boolean getQueueingDown()

getQueueingUp

public boolean getQueueingUp()

getUpVector

public Vector getUpVector()

providedDownServices

public Vector providedDownServices()

providedUpServices

public Vector providedUpServices()

setObserver

public void setObserver(QUEUE.Observer observer)
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)
Queues or passes up events. No queue sync. necessary, as this method is never called concurrently.
Copyright ? 1998-2005 Bela Ban. All Rights Reserved.