Class AbstractLockingInterceptor

    • Constructor Detail

      • AbstractLockingInterceptor

        public AbstractLockingInterceptor()
    • Method Detail

      • start

        public void start()
      • getLog

        protected abstract org.infinispan.util.logging.Log getLog()
      • visitClearCommand

        public final java.lang.Object visitClearCommand​(InvocationContext ctx,
                                                        org.infinispan.commands.write.ClearCommand command)
                                                 throws java.lang.Throwable
        Specified by:
        visitClearCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitClearCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitPutKeyValueCommand

        public java.lang.Object visitPutKeyValueCommand​(InvocationContext ctx,
                                                        org.infinispan.commands.write.PutKeyValueCommand command)
                                                 throws java.lang.Throwable
        Specified by:
        visitPutKeyValueCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitPutKeyValueCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReplaceCommand

        public java.lang.Object visitReplaceCommand​(InvocationContext ctx,
                                                    org.infinispan.commands.write.ReplaceCommand command)
                                             throws java.lang.Throwable
        Specified by:
        visitReplaceCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReplaceCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitComputeCommand

        public java.lang.Object visitComputeCommand​(InvocationContext ctx,
                                                    org.infinispan.commands.write.ComputeCommand command)
                                             throws java.lang.Throwable
        Specified by:
        visitComputeCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitComputeCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitComputeIfAbsentCommand

        public java.lang.Object visitComputeIfAbsentCommand​(InvocationContext ctx,
                                                            org.infinispan.commands.write.ComputeIfAbsentCommand command)
                                                     throws java.lang.Throwable
        Specified by:
        visitComputeIfAbsentCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitComputeIfAbsentCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitRemoveCommand

        public java.lang.Object visitRemoveCommand​(InvocationContext ctx,
                                                   org.infinispan.commands.write.RemoveCommand command)
                                            throws java.lang.Throwable
        Specified by:
        visitRemoveCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitRemoveCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitGetKeyValueCommand

        public java.lang.Object visitGetKeyValueCommand​(InvocationContext ctx,
                                                        org.infinispan.commands.read.GetKeyValueCommand command)
                                                 throws java.lang.Throwable
        Specified by:
        visitGetKeyValueCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitGetKeyValueCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitGetCacheEntryCommand

        public java.lang.Object visitGetCacheEntryCommand​(InvocationContext ctx,
                                                          org.infinispan.commands.read.GetCacheEntryCommand command)
                                                   throws java.lang.Throwable
        Specified by:
        visitGetCacheEntryCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitGetCacheEntryCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitDataReadCommand

        protected abstract java.lang.Object visitDataReadCommand​(InvocationContext ctx,
                                                                 org.infinispan.commands.DataCommand command)
                                                          throws java.lang.Throwable
        Throws:
        java.lang.Throwable
      • visitDataWriteCommand

        protected abstract java.lang.Object visitDataWriteCommand​(InvocationContext ctx,
                                                                  org.infinispan.commands.write.DataWriteCommand command)
                                                           throws java.lang.Throwable
        Throws:
        java.lang.Throwable
      • visitInvalidateCommand

        public final java.lang.Object visitInvalidateCommand​(InvocationContext ctx,
                                                             org.infinispan.commands.write.InvalidateCommand command)
                                                      throws java.lang.Throwable
        Specified by:
        visitInvalidateCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitInvalidateCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitInvalidateL1Command

        public final java.lang.Object visitInvalidateL1Command​(InvocationContext ctx,
                                                               org.infinispan.commands.write.InvalidateL1Command command)
                                                        throws java.lang.Throwable
        Specified by:
        visitInvalidateL1Command in interface org.infinispan.commands.Visitor
        Overrides:
        visitInvalidateL1Command in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitPutMapCommand

        public java.lang.Object visitPutMapCommand​(InvocationContext ctx,
                                                   org.infinispan.commands.write.PutMapCommand command)
                                            throws java.lang.Throwable
        Specified by:
        visitPutMapCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitPutMapCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReadWriteKeyValueCommand

        public java.lang.Object visitReadWriteKeyValueCommand​(InvocationContext ctx,
                                                              org.infinispan.commands.functional.ReadWriteKeyValueCommand command)
                                                       throws java.lang.Throwable
        Specified by:
        visitReadWriteKeyValueCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReadWriteKeyValueCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReadWriteKeyCommand

        public java.lang.Object visitReadWriteKeyCommand​(InvocationContext ctx,
                                                         org.infinispan.commands.functional.ReadWriteKeyCommand command)
                                                  throws java.lang.Throwable
        Specified by:
        visitReadWriteKeyCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReadWriteKeyCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitWriteOnlyKeyValueCommand

        public java.lang.Object visitWriteOnlyKeyValueCommand​(InvocationContext ctx,
                                                              org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)
                                                       throws java.lang.Throwable
        Specified by:
        visitWriteOnlyKeyValueCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitWriteOnlyKeyValueCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitWriteOnlyKeyCommand

        public java.lang.Object visitWriteOnlyKeyCommand​(InvocationContext ctx,
                                                         org.infinispan.commands.functional.WriteOnlyKeyCommand command)
                                                  throws java.lang.Throwable
        Specified by:
        visitWriteOnlyKeyCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitWriteOnlyKeyCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReadOnlyKeyCommand

        public java.lang.Object visitReadOnlyKeyCommand​(InvocationContext ctx,
                                                        org.infinispan.commands.functional.ReadOnlyKeyCommand command)
                                                 throws java.lang.Throwable
        Specified by:
        visitReadOnlyKeyCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReadOnlyKeyCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitWriteOnlyManyEntriesCommand

        public java.lang.Object visitWriteOnlyManyEntriesCommand​(InvocationContext ctx,
                                                                 org.infinispan.commands.functional.WriteOnlyManyEntriesCommand command)
                                                          throws java.lang.Throwable
        Specified by:
        visitWriteOnlyManyEntriesCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitWriteOnlyManyEntriesCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitWriteOnlyManyCommand

        public java.lang.Object visitWriteOnlyManyCommand​(InvocationContext ctx,
                                                          org.infinispan.commands.functional.WriteOnlyManyCommand command)
                                                   throws java.lang.Throwable
        Specified by:
        visitWriteOnlyManyCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitWriteOnlyManyCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReadWriteManyCommand

        public java.lang.Object visitReadWriteManyCommand​(InvocationContext ctx,
                                                          org.infinispan.commands.functional.ReadWriteManyCommand command)
                                                   throws java.lang.Throwable
        Specified by:
        visitReadWriteManyCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReadWriteManyCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReadWriteManyEntriesCommand

        public java.lang.Object visitReadWriteManyEntriesCommand​(InvocationContext ctx,
                                                                 org.infinispan.commands.functional.ReadWriteManyEntriesCommand command)
                                                          throws java.lang.Throwable
        Specified by:
        visitReadWriteManyEntriesCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReadWriteManyEntriesCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitGetAllCommand

        public java.lang.Object visitGetAllCommand​(InvocationContext ctx,
                                                   org.infinispan.commands.read.GetAllCommand command)
                                            throws java.lang.Throwable
        Specified by:
        visitGetAllCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitGetAllCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • visitReadOnlyManyCommand

        public java.lang.Object visitReadOnlyManyCommand​(InvocationContext ctx,
                                                         org.infinispan.commands.functional.ReadOnlyManyCommand command)
                                                  throws java.lang.Throwable
        Specified by:
        visitReadOnlyManyCommand in interface org.infinispan.commands.Visitor
        Overrides:
        visitReadOnlyManyCommand in class DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • handleReadManyCommand

        protected abstract java.lang.Object handleReadManyCommand​(InvocationContext ctx,
                                                                  org.infinispan.commands.FlagAffectedCommand command,
                                                                  java.util.Collection<?> keys)
                                                           throws java.lang.Throwable
        Throws:
        java.lang.Throwable
      • handleWriteManyCommand

        protected abstract <K> java.lang.Object handleWriteManyCommand​(InvocationContext ctx,
                                                                       org.infinispan.commands.write.WriteCommand command,
                                                                       java.util.Collection<K> keys,
                                                                       boolean forwarded)
                                                                throws java.lang.Throwable
        Throws:
        java.lang.Throwable
      • getLockTimeoutMillis

        protected final long getLockTimeoutMillis​(org.infinispan.commands.FlagAffectedCommand command)