Class TotalOrderDistributionInterceptor

  • All Implemented Interfaces:
    org.infinispan.commands.Visitor, AsyncInterceptor

    public class TotalOrderDistributionInterceptor
    extends TxDistributionInterceptor
    This interceptor handles distribution of entries across a cluster, as well as transparent lookup, when the total order based protocol is enabled
    Author:
    Pedro Ruivo
    • Constructor Detail

      • TotalOrderDistributionInterceptor

        public TotalOrderDistributionInterceptor()
    • Method Detail

      • start

        public void start()
      • visitRollbackCommand

        public java.lang.Object visitRollbackCommand​(org.infinispan.context.impl.TxInvocationContext ctx,
                                                     org.infinispan.commands.tx.RollbackCommand command)
                                              throws java.lang.Throwable
        Specified by:
        visitRollbackCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitRollbackCommand in class TxDistributionInterceptor
        Throws:
        java.lang.Throwable
      • visitCommitCommand

        public java.lang.Object visitCommitCommand​(org.infinispan.context.impl.TxInvocationContext ctx,
                                                   org.infinispan.commands.tx.CommitCommand command)
                                            throws java.lang.Throwable
        Specified by:
        visitCommitCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitCommitCommand in class TxDistributionInterceptor
        Throws:
        java.lang.Throwable
      • prepareOnAffectedNodes

        protected java.util.concurrent.CompletionStage<java.lang.Object> prepareOnAffectedNodes​(org.infinispan.context.impl.TxInvocationContext<?> ctx,
                                                                                                org.infinispan.commands.tx.PrepareCommand command,
                                                                                                java.util.Collection<Address> recipients)
        Overrides:
        prepareOnAffectedNodes in class TxDistributionInterceptor