Class AbstractAmqpOutboundEndpoint.CorrelationDataWrapper
java.lang.Object
org.springframework.amqp.rabbit.connection.CorrelationData
org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint.CorrelationDataWrapper
- All Implemented Interfaces:
org.springframework.amqp.core.Correlation
- Enclosing class:
- AbstractAmqpOutboundEndpoint
protected static final class AbstractAmqpOutboundEndpoint.CorrelationDataWrapper
extends org.springframework.amqp.rabbit.connection.CorrelationData
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.connection.CorrelationData
org.springframework.amqp.rabbit.connection.CorrelationData.Confirm -
Method Summary
Modifier and TypeMethodDescriptionCompletableFuture<org.springframework.amqp.rabbit.connection.CorrelationData.Confirm>org.springframework.messaging.Message<?>voidsetReturned(org.springframework.amqp.core.ReturnedMessage returned) Methods inherited from class org.springframework.amqp.rabbit.connection.CorrelationData
getId, getReturned, setId, toString
-
Method Details
-
getUserData
-
getMessage
public org.springframework.messaging.Message<?> getMessage() -
getFuture
public CompletableFuture<org.springframework.amqp.rabbit.connection.CorrelationData.Confirm> getFuture()- Overrides:
getFuturein classorg.springframework.amqp.rabbit.connection.CorrelationData
-
setReturned
public void setReturned(org.springframework.amqp.core.ReturnedMessage returned) - Overrides:
setReturnedin classorg.springframework.amqp.rabbit.connection.CorrelationData
-