|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jgroups.stack.Protocol
org.jgroups.protocols.QUEUE
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.
Nested Class Summary | |
static interface |
QUEUE.Observer
|
Field Summary |
Fields inherited from class org.jgroups.stack.Protocol |
down_handler, down_prot, down_queue, down_thread, down_thread_prio, props, stack, up_handler, up_prot, up_queue, up_thread, up_thread_prio |
Constructor Summary | |
QUEUE()
|
Method Summary | |
void |
down(Event evt)
An event is to be sent down the stack. |
java.util.Vector |
getDownVector()
|
java.lang.String |
getName()
All protocol names have to be unique ! |
boolean |
getQueueingDown()
|
boolean |
getQueueingUp()
|
java.util.Vector |
getUpVector()
|
java.util.Vector |
providedDownServices()
List of events that are provided to layers below (they will be handled when sent down from below). |
java.util.Vector |
providedUpServices()
List of events that are provided to layers above (they will be handled when sent down from above). |
void |
setObserver(QUEUE.Observer observer)
Only 1 observer is allowed. |
boolean |
setProperties(java.util.Properties props)
Configures the protocol initially. |
void |
up(Event evt)
Queues or passes up events. |
Methods inherited from class org.jgroups.stack.Protocol |
destroy, getDownProtocol, getDownQueue, getProperties, getUpProtocol, getUpQueue, init, passDown, passUp, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, setDownProtocol, setObserver, setPropertiesInternal, setProtocolStack, setUpProtocol, start, startDownHandler, startUpHandler, stop, stopInternal |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public QUEUE()
Method Detail |
public void setObserver(QUEUE.Observer observer)
public java.util.Vector getUpVector()
public java.util.Vector getDownVector()
public boolean getQueueingUp()
public boolean getQueueingDown()
public java.lang.String getName()
getName
in class Protocol
public java.util.Vector providedUpServices()
Protocol
providedUpServices
in class Protocol
public java.util.Vector providedDownServices()
Protocol
providedDownServices
in class Protocol
public boolean setProperties(java.util.Properties props)
Protocol
"loopback=false;unicast_inport=4444"
setProperties
in class Protocol
public void up(Event evt)
up
in class Protocol
public void down(Event evt)
Protocol
passDown()
. In case of a GET_ADDRESS event (which tries to
retrieve the stack's address from one of the bottom layers), the layer may need to send
a new response event back up the stack using passUp()
.
down
in class Protocol
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |