public class ResponseCollector<T>
extends java.lang.Object
Constructor | Description |
---|---|
ResponseCollector() |
|
ResponseCollector(java.util.Collection<Address> members) |
Modifier and Type | Method | Description |
---|---|---|
void |
add(Address member,
T data) |
|
java.util.Map<Address,T> |
getResults() |
|
boolean |
hasAllResponses() |
|
void |
remove(Address member) |
|
void |
reset() |
|
void |
reset(java.util.Collection<Address> members) |
|
int |
size() |
|
void |
suspect(Address member) |
|
java.lang.String |
toString() |
|
boolean |
waitForAllResponses(long timeout) |
Waits until all responses have been received, or until a timeout has elapsed.
|
public ResponseCollector(java.util.Collection<Address> members)
members
- List of members from which we expect responsespublic ResponseCollector()
public void remove(Address member)
public void suspect(Address member)
public boolean hasAllResponses()
public int size()
public boolean waitForAllResponses(long timeout)
timeout
- Number of milliseconds to wait max. This value needs to be greater than 0, or else
it will be adjusted to 2000public void reset()
public void reset(java.util.Collection<Address> members)
public java.lang.String toString()
toString
in class java.lang.Object
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.