@ThreadSafe public class Responses extends Object implements Iterable<org.jgroups.util.Rsp<Response>>
null
.
This class is safe against concurrent access by multiple threads.Constructor and Description |
---|
Responses(Collection<org.jgroups.Address> addresses) |
Responses(org.jgroups.util.RspList<Response> results)
Constructs new instance using existing
RspList . |
Modifier and Type | Method and Description |
---|---|
void |
addResponse(org.jgroups.util.Rsp rsp) |
boolean |
isMissingResponses() |
boolean |
isTimedOut() |
Iterator<org.jgroups.util.Rsp<Response>> |
iterator() |
void |
setTimedOut() |
int |
size() |
static Responses |
suspected(Collection<org.jgroups.Address> dests)
Constructs a new instance with responses from all recipients marked
as suspected.
|
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
forEach, spliterator
public static final Responses EMPTY
public Responses(Collection<org.jgroups.Address> addresses)
public Responses(org.jgroups.util.RspList<Response> results)
RspList
. If the response
was not received and the node was neither marked as suspected nor unreachable
the response in this instance will be null
.results
- Received responses.public static Responses suspected(Collection<org.jgroups.Address> dests)
dests
- Collection of recipients.public void addResponse(org.jgroups.util.Rsp rsp)
public boolean isMissingResponses()
public int size()
public void setTimedOut()
public boolean isTimedOut()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.