public class ClusterNodeResponses
extends Object
implements Serializable
Constructor and Description |
---|
ClusterNodeResponses(Set<String> expectedReplyNodeIds) |
Modifier and Type | Method and Description |
---|---|
boolean |
addClusterResponse(ClusterNodeResponse clusterNodeResponse) |
ClusterNodeResponse |
getClusterResponse(String clusterNodeId) |
BlockingQueue<ClusterNodeResponse> |
getClusterResponses() |
int |
size() |
public ClusterNodeResponses(Set<String> expectedReplyNodeIds)
public boolean addClusterResponse(ClusterNodeResponse clusterNodeResponse)
public ClusterNodeResponse getClusterResponse(String clusterNodeId)
public BlockingQueue<ClusterNodeResponse> getClusterResponses()
public int size()