org.infinispan.remoting.transport.jgroups

Class JGroupsResponseFilterAdapter

java.lang.Object

org.infinispan.remoting.transport.jgroups.JGroupsResponseFilterAdapter

All Implemented Interfaces:

RspFilter

public final class JGroupsResponseFilterAdapter
extends Object
implements RspFilter

Acts as a bridge between JGroups RspFilter and ResponseFilter.

Since:

4.0

Author:

Manik Surtani, Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
JGroupsResponseFilterAdapter(ResponseFilter r) Creates an instance of the adapter

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isAcceptable(Object 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 RspFilter.isAcceptable(Object, org.jgroups.Address), this method is called to see whether we are done with the request and can unblock the caller

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JGroupsResponseFilterAdapter

public JGroupsResponseFilterAdapter(ResponseFilter r)

Creates an instance of the adapter

Parameters:

r - response filter to wrap

Method Detail

isAcceptable

public boolean isAcceptable(Object response,
                   Address sender)

Description copied from interface: RspFilter

Determines whether a response from a given sender should be added to the response list of the request

Specified by:

isAcceptable in interface RspFilter

Parameters:

response - The response (usually a serializable value)

sender - The sender of response

Returns:

True if we should add the response to the response list (RspList) of a request, otherwise false. In the latter case, we don't add the response to the response list.

needMoreResponses

public boolean needMoreResponses()

Description copied from interface: RspFilter

Right after calling RspFilter.isAcceptable(Object, org.jgroups.Address), this method is called to see whether we are done with the request and can unblock the caller

Specified by:

needMoreResponses in interface RspFilter

Returns:

False if the request is done, otherwise true