S - the spec subclass type.public abstract class AmqpOutboundEndpointSpec<S extends AmqpOutboundEndpointSpec<S>> extends AmqpBaseOutboundEndpointSpec<S,AmqpOutboundEndpoint>
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
expectReply |
headerMapper| Modifier | Constructor and Description |
|---|---|
protected |
AmqpOutboundEndpointSpec(org.springframework.amqp.core.AmqpTemplate amqpTemplate,
boolean expectReply) |
| Modifier and Type | Method and Description |
|---|---|
S |
mappedReplyHeaders(java.lang.String... headers)
Provide the header names that should be mapped to a response
from a
MessageHeaders. |
S |
waitForConfirm(boolean waitForConfirm)
Wait for a publisher confirm.
|
confirmAckChannel, confirmCorrelationExpression, confirmCorrelationExpression, confirmCorrelationFunction, confirmNackChannel, confirmTimeout, defaultDeliveryMode, delay, delayExpression, delayExpression, delayFunction, errorMessageStrategy, exchangeName, exchangeNameExpression, exchangeNameExpression, exchangeNameFunction, headerMapper, headersMappedLast, lazyConnect, mappedRequestHeaders, returnChannel, routingKey, routingKeyExpression, routingKeyExpression, routingKeyFunction_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopprotected AmqpOutboundEndpointSpec(org.springframework.amqp.core.AmqpTemplate amqpTemplate,
boolean expectReply)
public S mappedReplyHeaders(java.lang.String... headers)
AmqpBaseOutboundEndpointSpecMessageHeaders.mappedReplyHeaders in class AmqpBaseOutboundEndpointSpec<S extends AmqpOutboundEndpointSpec<S>,AmqpOutboundEndpoint>headers - The reply header names.public S waitForConfirm(boolean waitForConfirm)
waitForConfirm - true to wait.AmqpOutboundEndpoint.setWaitForConfirm(boolean)