|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.jboss.messaging.core.plugin.postoffice.cluster.RoundRobinRouter
This router first favours the failed over queue (if there is one) TODO revisit this Then it will round robin between the non queues. FIXME - none of the new failed over functionality has been tested!!
| Constructor Summary | |
RoundRobinRouter()
|
|
| Method Summary | |
boolean |
add(Receiver receiver)
Add a local receiver to this distributor. |
boolean |
add(Receiver receiver,
boolean failedOver)
|
void |
clear()
Remove all receivers. |
boolean |
contains(Receiver queue)
|
Queue |
getLocalQueue()
|
int |
getNumberOfReceivers()
|
java.util.List |
getQueues()
|
Delivery |
handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
A receiver can return an active, "done" or null delivery. |
java.util.Iterator |
iterator()
|
boolean |
remove(Receiver queue)
Remove a local receiver from this distributor. |
int |
size()
|
java.lang.String |
toString()
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Constructor Detail |
public RoundRobinRouter()
| Method Detail |
public Delivery handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
Receiver
handle in interface Receiverobserver - - the component the delivery should be acknowledged to.Delivery,
DeliveryObserverpublic boolean contains(Receiver queue)
contains in interface Distributorpublic java.util.Iterator iterator()
iterator in interface Distributorpublic boolean add(Receiver receiver)
Distributor
add in interface ClusterRouterpublic boolean remove(Receiver queue)
Distributor
remove in interface Distributorpublic void clear()
Distributor
clear in interface Distributorpublic int getNumberOfReceivers()
getNumberOfReceivers in interface Distributorpublic java.util.List getQueues()
getQueues in interface ClusterRouter
public boolean add(Receiver receiver,
boolean failedOver)
public Queue getLocalQueue()
getLocalQueue in interface ClusterRouterpublic int size()
public java.lang.String toString()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||