org.springframework.amqp.rabbit

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>, ListenableFuture<T>

Direct Known Subclasses:

AsyncRabbitTemplate.RabbitConverterFuture, AsyncRabbitTemplate.RabbitMessageFuture

Enclosing class:

AsyncRabbitTemplate

public abstract class AsyncRabbitTemplate.RabbitFuture<T>
extends SettableListenableFuture<T>

Base class for ListenableFutures returned by AsyncRabbitTemplate.

Since:

1.6

Constructor Summary

Constructors

Constructor and Description
RabbitFuture(String correlationId, Message requestMessage)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
ListenableFuture<Boolean>	getConfirm() When confirms are enabled contains a ListenableFuture for the confirmation.
String	getNackCause() 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 Detail

RabbitFuture

public RabbitFuture(String correlationId,
                    Message requestMessage)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

Overrides:

cancel in class SettableListenableFuture<T>

getConfirm

public 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.