org.infinispan.remoting.transport.jgroups

Class CustomRequestCorrelator

java.lang.Object

org.jgroups.blocks.RequestCorrelator

org.infinispan.remoting.transport.jgroups.CustomRequestCorrelator

public class CustomRequestCorrelator
extends org.jgroups.blocks.RequestCorrelator

Extend RequestCorrelator to ignore Event.SUSPECT events. SuspectException will only be thrown when the target actually leaves the view.

Since:

7.2

Author:

Dan Berindei

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.blocks.RequestCorrelator

org.jgroups.blocks.RequestCorrelator.Header, org.jgroups.blocks.RequestCorrelator.MultiDestinationHeader, org.jgroups.blocks.RequestCorrelator.MyProbeHandler, org.jgroups.blocks.RequestCorrelator.ResponseImpl

Field Summary

Fields inherited from class org.jgroups.blocks.RequestCorrelator

async_dispatching, corr_id, local_addr, log, marshaller, probe_handler, request_handler, REQUEST_ID, requests, rpc_stats, started, transport, view, wrap_exceptions

Constructor Summary

Constructors

Constructor and Description
CustomRequestCorrelator(org.jgroups.stack.Protocol transport, org.jgroups.blocks.RequestHandler handler, org.jgroups.Address local_addr)

Method Summary

Modifier and Type	Method and Description
void	receiveSuspect(org.jgroups.Address mbr)

Methods inherited from class org.jgroups.blocks.RequestCorrelator

asyncDispatching, asyncDispatching, dispatch, done, getLocalAddress, getMarshaller, handleRequest, prepareResponse, receive, receiveMessage, receiveMessageBatch, receiveView, registerProbeHandler, removeEntry, sendReply, sendRequest, sendRequest, sendResponse, sendUnicastRequest, setLocalAddress, setMarshaller, setRequestHandler, setSiteUnreachable, start, stop, unregisterProbeHandler, wrapExceptions, wrapExceptions

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomRequestCorrelator

public CustomRequestCorrelator(org.jgroups.stack.Protocol transport,
                               org.jgroups.blocks.RequestHandler handler,
                               org.jgroups.Address local_addr)

Method Detail

receiveSuspect

public void receiveSuspect(org.jgroups.Address mbr)

Overrides:

receiveSuspect in class org.jgroups.blocks.RequestCorrelator