Class OptimisticLockingInterceptor

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

    public class OptimisticLockingInterceptor
    extends AbstractTxLockingInterceptor
    Locking interceptor to be used by optimistic transactional caches.
    Author:
    Mircea Markus
    • Constructor Detail

      • OptimisticLockingInterceptor

        public OptimisticLockingInterceptor()
    • Method Detail

      • visitPrepareCommand

        public java.lang.Object visitPrepareCommand​(org.infinispan.context.impl.TxInvocationContext ctx,
                                                    org.infinispan.commands.tx.PrepareCommand command)
                                             throws java.lang.Throwable
        Specified by:
        visitPrepareCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitPrepareCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • handleWriteManyCommand

        protected <K> java.lang.Object handleWriteManyCommand​(InvocationContext ctx,
                                                              org.infinispan.commands.write.WriteCommand command,
                                                              java.util.Collection<K> keys,
                                                              boolean forwarded)
                                                       throws java.lang.Throwable
        Specified by:
        handleWriteManyCommand in class AbstractLockingInterceptor
        Throws:
        java.lang.Throwable
      • visitLockControlCommand

        public java.lang.Object visitLockControlCommand​(org.infinispan.context.impl.TxInvocationContext ctx,
                                                        org.infinispan.commands.control.LockControlCommand command)
                                                 throws java.lang.Throwable
        Specified by:
        visitLockControlCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitLockControlCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable