Class StateTransferInterceptor

  • All Implemented Interfaces:
    Visitor, AsyncInterceptor

    public class StateTransferInterceptor
    extends BaseStateTransferInterceptor
    This interceptor has two tasks:
    1. If the command's topology id is higher than the current topology id, wait for the node to receive transaction data for the new topology id.
    2. If the topology id changed during a command's execution, retry the command, but only on the originator (which replicates it to the new owners).
    If the cache is configured with asynchronous replication, owners cannot signal to the originator that they saw a new topology, so instead each owner forwards the command to all the other owners in the new topology.
    Author:
    anistor@redhat.com