Class AsyncRabbitTemplate.RabbitFuture<T>

java.lang.Object
org.springframework.util.concurrent.SettableListenableFuture<T>
org.springframework.amqp.rabbit.AsyncRabbitTemplate.RabbitFuture<T>
Type Parameters:
T - the type.
All Implemented Interfaces:
Future<T>, org.springframework.util.concurrent.ListenableFuture<T>
Direct Known Subclasses:
AsyncRabbitTemplate.RabbitConverterFuture, AsyncRabbitTemplate.RabbitMessageFuture
Enclosing class:
AsyncRabbitTemplate

public abstract class AsyncRabbitTemplate.RabbitFuture<T> extends org.springframework.util.concurrent.SettableListenableFuture<T>
Base class for ListenableFutures returned by AsyncRabbitTemplate.
Since:
1.6
  • Constructor Summary

    Constructors
    Constructor
    Description
    RabbitFuture(String correlationId, org.springframework.amqp.core.Message requestMessage)
     
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    cancel(boolean mayInterruptIfRunning)
     
    org.springframework.util.concurrent.ListenableFuture<Boolean>
    When confirms are enabled contains a ListenableFuture for the confirmation.
    When confirms are enabled and a nack is received, contains the cause for the nack, if any.

    Methods inherited from class org.springframework.util.concurrent.SettableListenableFuture

    addCallback, addCallback, completable, get, get, interruptTask, isCancelled, isDone, set, setException

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • RabbitFuture

      public RabbitFuture(String correlationId, org.springframework.amqp.core.Message requestMessage)
  • Method Details

    • cancel

      public boolean cancel(boolean mayInterruptIfRunning)
      Specified by:
      cancel in interface Future<T>
      Overrides:
      cancel in class org.springframework.util.concurrent.SettableListenableFuture<T>
    • getConfirm

      public org.springframework.util.concurrent.ListenableFuture<Boolean> getConfirm()
      When confirms are enabled contains a ListenableFuture for the confirmation.
      Returns:
      the future.
    • getNackCause

      public String getNackCause()
      When confirms are enabled and a nack is received, contains the cause for the nack, if any.
      Returns:
      the cause.