Package org.jgroups.util
Class ResponseCollector<T>
- java.lang.Object
-
- org.jgroups.util.ResponseCollector<T>
-
public class ResponseCollector<T> extends java.lang.Object
Similar to AckCollector, but collects responses, not just acks. Null is not a valid key.- Version:
- $Id: ResponseCollector.java,v 1.1.2.5 2009/04/21 10:09:22 belaban Exp $
- Author:
- Bela Ban
-
-
Constructor Summary
Constructors Constructor Description ResponseCollector()
ResponseCollector(java.util.Collection<Address> members)
-
Method Summary
All Methods Instance Methods Concrete Methods 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.
-
-
-
Constructor Detail
-
ResponseCollector
public ResponseCollector(java.util.Collection<Address> members)
- Parameters:
members
- List of members from which we expect responses
-
ResponseCollector
public ResponseCollector()
-
-
Method Detail
-
remove
public void remove(Address member)
-
suspect
public void suspect(Address member)
-
hasAllResponses
public boolean hasAllResponses()
-
size
public int size()
-
waitForAllResponses
public boolean waitForAllResponses(long timeout)
Waits until all responses have been received, or until a timeout has elapsed.- Parameters:
timeout
- Number of milliseconds to wait max. This value needs to be greater than 0, or else it will be adjusted to 2000- Returns:
- boolean True if all responses have been received within timeout ms, else false (e.g. if interrupted)
-
reset
public void reset()
-
reset
public void reset(java.util.Collection<Address> members)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-