public class AmqpOutboundEndpointSpec extends AmqpBaseOutboundEndpointSpec<AmqpOutboundEndpointSpec,AmqpOutboundEndpoint>
headerMapper
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Modifier and Type | Method and Description |
---|---|
AmqpOutboundEndpointSpec |
mappedReplyHeaders(String... headers)
Provide the header names that should be mapped to a response
from a
MessageHeaders . |
AmqpOutboundEndpointSpec |
waitForConfirm(boolean waitForConfirm)
Wait for a publisher confirm.
|
confirmAckChannel, confirmCorrelationExpression, confirmCorrelationExpression, confirmCorrelationFunction, confirmNackChannel, 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, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
public AmqpOutboundEndpointSpec mappedReplyHeaders(String... headers)
AmqpBaseOutboundEndpointSpec
MessageHeaders
.mappedReplyHeaders
in class AmqpBaseOutboundEndpointSpec<AmqpOutboundEndpointSpec,AmqpOutboundEndpoint>
headers
- The reply header names.public AmqpOutboundEndpointSpec waitForConfirm(boolean waitForConfirm)
waitForConfirm
- true to wait.AmqpOutboundEndpoint.setWaitForConfirm(boolean)