public class SelfDeliverFilter extends Object implements TimeoutValidationResponseFilter
Constructor and Description |
---|
SelfDeliverFilter(Address localAddress) |
Modifier and Type | Method and Description |
---|---|
boolean |
isAcceptable(Response response,
Address sender)
Determines whether a response from a given sender should be added to the response list of the request
|
boolean |
needMoreResponses()
Right after calling
ResponseFilter.isAcceptable(Response, Address) , this method is called to see whether we are done
with the request and can unblock the caller |
void |
validate()
Validates the filter state.
|
public SelfDeliverFilter(Address localAddress)
public boolean isAcceptable(Response response, Address sender)
ResponseFilter
isAcceptable
in interface ResponseFilter
response
- The response (usually a serializable value)sender
- The sender of responsepublic boolean needMoreResponses()
ResponseFilter
ResponseFilter.isAcceptable(Response, Address)
, this method is called to see whether we are done
with the request and can unblock the callerneedMoreResponses
in interface ResponseFilter
public void validate() throws TimeoutException
TimeoutValidationResponseFilter
TimeoutException
validate
in interface TimeoutValidationResponseFilter
TimeoutException
- when a member didn't give a response.Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.