Package org.infinispan.remoting.transport.jgroups

Class SingleSiteRequest<T>

  • All Implemented Interfaces:
    java.util.concurrent.Callable<java.lang.Void>, java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<T>, org.infinispan.remoting.transport.impl.Request<T>
    public class SingleSiteRequest<T>
extends AbstractRequest<T>
    Request implementation that waits for a response from a single target site.
    Since:
    9.1
    Author:
    Dan Berindei

    • Nested Class Summary

      • Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

        java.util.concurrent.CompletableFuture.AsynchronousCompletionTask

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean onNewView​(java.util.Set<Address> members)
      Called when the node received a new cluster view.
      void onResponse​(Address sender, Response response)
      Called when a response is received for this response.
      protected void onTimeout()
      Called when the timeout task scheduled with AbstractRequest.setTimeout(ScheduledExecutorService, long, TimeUnit) expires.
      void sitesUnreachable​(java.lang.String unreachableSite)  

      • Methods inherited from class java.util.concurrent.CompletableFuture

        acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, completeAsync, completeAsync, completedFuture, completedStage, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

      • Methods inherited from interface java.util.concurrent.CompletionStage

        acceptEither, acceptEitherAsync, acceptEitherAsync, applyToEither, applyToEitherAsync, applyToEitherAsync, exceptionally, handle, handleAsync, handleAsync, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, whenComplete, whenCompleteAsync, whenCompleteAsync

    • Method Detail

      • onResponse

        public void onResponse​(Address sender,
                       Response response)
        Description copied from interface: org.infinispan.remoting.transport.impl.Request
        Called when a response is received for this response.

      • onNewView

        public boolean onNewView​(java.util.Set<Address> members)
        Description copied from interface: org.infinispan.remoting.transport.impl.Request
        Called when the node received a new cluster view.
        Returns:
        true if any of the request targets is not in the view.

      • sitesUnreachable

        public void sitesUnreachable​(java.lang.String unreachableSite)