public class LoadBalanceSelector extends java.lang.Object implements DestinationSelector
| Constructor and Description |
|---|
LoadBalanceSelector() |
| Modifier and Type | Method and Description |
|---|---|
void |
commit(int source,
int dest)
Say that we have used the obtained destination
|
int |
next(int source,
java.lang.Object data)
Get next destination using source and the data
|
int |
next(int source,
java.lang.Object key,
java.lang.Object data)
Get next destination using source, key and data
|
void |
prepare(Communicator comm,
java.util.Set<java.lang.Integer> sources,
java.util.Set<java.lang.Integer> destinations)
Prepare the destination selector
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpreparepublic void prepare(Communicator comm, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations)
DestinationSelectorprepare in interface DestinationSelectorcomm - the communicatorsources - sourcesdestinations - destinationpublic int next(int source,
java.lang.Object key,
java.lang.Object data)
DestinationSelectornext in interface DestinationSelectorsource - sourcekey - keydata - datapublic int next(int source,
java.lang.Object data)
DestinationSelectornext in interface DestinationSelectorsource - sourcedata - datapublic void commit(int source,
int dest)
DestinationSelectorcommit in interface DestinationSelectorsource - sourcedest - obtained destination