Class TxDistributionInterceptor

    • Constructor Detail

      • TxDistributionInterceptor

        public TxDistributionInterceptor()
    • Method Detail

      • 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
      • 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
      • 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
      • 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
      • 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
      • 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
      • 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
      • 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
      • 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
      • 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 DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • 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
      • 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)
      • 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 DDAsyncInterceptor
        Throws:
        java.lang.Throwable
      • checkTxCommandResponses

        protected void checkTxCommandResponses​(java.util.Map<Address,​Response> responseMap,
                                               org.infinispan.commands.tx.TransactionBoundaryCommand command,
                                               org.infinispan.context.impl.TxInvocationContext<org.infinispan.transaction.impl.LocalTransaction> context,
                                               java.util.Collection<Address> recipients)
      • handleTxWriteManyEntriesCommand

        protected <C extends org.infinispan.commands.TopologyAffectedCommand & org.infinispan.commands.FlagAffectedCommand,​K,​V> java.lang.Object handleTxWriteManyEntriesCommand​(InvocationContext ctx,
                                                                                                                                                                                             C command,
                                                                                                                                                                                             java.util.Map<K,​V> entries,
                                                                                                                                                                                             java.util.function.BiFunction<C,​java.util.Map<K,​V>,​C> copyCommand)
      • handleTxWriteManyCommand

        protected <C extends org.infinispan.commands.VisitableCommand & org.infinispan.commands.FlagAffectedCommand & org.infinispan.commands.TopologyAffectedCommand,​K> java.lang.Object handleTxWriteManyCommand​(InvocationContext ctx,
                                                                                                                                                                                                                         C command,
                                                                                                                                                                                                                         java.util.Collection<K> keys,
                                                                                                                                                                                                                         java.util.function.BiFunction<C,​java.util.List<K>,​C> copyCommand)
      • handleTxFunctionalCommand

        public <C extends org.infinispan.commands.write.AbstractDataWriteCommand & org.infinispan.commands.functional.FunctionalCommand> java.lang.Object handleTxFunctionalCommand​(InvocationContext ctx,
                                                                                                                                                                                    C command)
      • 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 BaseDistributionInterceptor
        Throws:
        java.lang.Throwable
      • remoteGetSingleKey

        protected <C extends org.infinispan.commands.FlagAffectedCommand & org.infinispan.commands.TopologyAffectedCommand> java.util.concurrent.CompletionStage<java.lang.Void> remoteGetSingleKey​(InvocationContext ctx,
                                                                                                                                                                                                    C command,
                                                                                                                                                                                                    java.lang.Object key,
                                                                                                                                                                                                    boolean isWrite)
        Description copied from class: BaseDistributionInterceptor
        Fetch a key from its remote owners and store it in the context. Not thread-safe. The invocation context should not be accessed concurrently from multiple threads, so this method should only be used for single-key commands.
        Overrides:
        remoteGetSingleKey in class BaseDistributionInterceptor