Package org.infinispan.query.indexmanager

Class AbstractUpdateCommand

  • All Implemented Interfaces:
    org.infinispan.commands.remote.CacheRpcCommand, org.infinispan.commands.ReplicableCommand, org.infinispan.query.impl.CustomQueryCommand
    Direct Known Subclasses:
    AffinityUpdateCommand, IndexUpdateCommand, IndexUpdateStreamCommand
    public abstract class AbstractUpdateCommand
extends org.infinispan.commands.remote.BaseRpcCommand
implements org.infinispan.commands.ReplicableCommand, org.infinispan.query.impl.CustomQueryCommand
    Base class for index commands.
    Since:
    7.0
    Author:
    gustavonalle

    • Field Detail

      • searchFactory

        protected org.hibernate.search.spi.SearchIntegrator searchFactory

      • indexName

        protected String indexName

      • serializedModel

        protected byte[] serializedModel

      • queryInterceptor

        protected org.infinispan.query.backend.QueryInterceptor queryInterceptor

    • Constructor Detail

      • AbstractUpdateCommand

        protected AbstractUpdateCommand​(ByteString cacheName)

    • Method Detail

      • invokeAsync

        public abstract CompletableFuture<Object> invokeAsync()
                                               throws Throwable
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Invoke the command asynchronously.

        This method replaces ReplicableCommand.perform(InvocationContext) for remote execution. The default implementation and ReplicableCommand.perform(InvocationContext) will be removed in future versions.

        Specified by:
        invokeAsync in interface org.infinispan.commands.ReplicableCommand
        Throws:
        Throwable

      • getCommandId

        public abstract byte getCommandId()
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Used by marshallers to convert this command into an id for streaming.
        Specified by:
        getCommandId in interface org.infinispan.commands.ReplicableCommand
        Returns:
        the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.

      • writeTo

        public void writeTo​(ObjectOutput output)
             throws IOException
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Writes this instance to the ObjectOutput.
        Specified by:
        writeTo in interface org.infinispan.commands.ReplicableCommand
        Parameters:
        output - the stream.
        Throws:
        IOException - if an error occurred during the I/O.

      • readFrom

        public void readFrom​(ObjectInput input)
              throws IOException
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Reads this instance from the stream written by ReplicableCommand.writeTo(ObjectOutput).
        Specified by:
        readFrom in interface org.infinispan.commands.ReplicableCommand
        Parameters:
        input - the stream to read.
        Throws:
        IOException - if an error occurred during the I/O.

      • isReturnValueExpected

        public boolean isReturnValueExpected()
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        If true, a return value will be provided when performed remotely. Otherwise, a remote ResponseGenerator may choose to simply return null to save on marshalling costs.
        Specified by:
        isReturnValueExpected in interface org.infinispan.commands.ReplicableCommand
        Returns:
        true or false

      • setCacheManager

        public void setCacheManager​(EmbeddedCacheManager cm)
        This is invoked only on the receiving node, before ReplicableCommand.perform(org.infinispan.context.InvocationContext).
        Specified by:
        setCacheManager in interface org.infinispan.query.impl.CustomQueryCommand

      • canBlock

        public boolean canBlock()
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool. Otherwise, the command is processed directly in the JGroups thread.

        This feature allows to avoid keep a JGroups thread busy that can originate discard of messages and retransmissions. So, the commands that can block (waiting for some state, acquiring locks, etc.) should return true.

        Specified by:
        canBlock in interface org.infinispan.commands.ReplicableCommand
        Overrides:
        canBlock in class org.infinispan.commands.remote.BaseRpcCommand
        Returns:
        true if the command can block/wait, false otherwise

      • getIndexName

        public String getIndexName()

      • setSerializedWorkList

        protected void setSerializedWorkList​(byte[] serializedModel)

      • setIndexName

        public void setIndexName​(String indexName)