S - the target AmqpBaseOutboundEndpointSpec implementation type.E - the target AbstractAmqpOutboundEndpoint implementation type.public abstract class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends AbstractAmqpOutboundEndpoint> extends MessageHandlerSpec<S,E>
MessageHandlerSpec for AbstractAmqpOutboundEndpoints.| Modifier and Type | Field and Description |
|---|---|
protected DefaultAmqpHeaderMapper |
headerMapper |
logger, PARSER, target| Constructor and Description |
|---|
AmqpBaseOutboundEndpointSpec() |
_this, doGet, get, getId, getObject, getObjectType, id, isSingletonprotected final DefaultAmqpHeaderMapper headerMapper
public S headerMapper(AmqpHeaderMapper headerMapper)
public S defaultDeliveryMode(MessageDeliveryMode defaultDeliveryMode)
public S routingKeyFunction(java.util.function.Function<Message<?>,String> routingKeyFunction)
public S routingKeyExpression(Expression routingKeyExpression)
public S returnChannel(MessageChannel returnChannel)
public S confirmAckChannel(MessageChannel ackChannel)
public S exchangeNameFunction(java.util.function.Function<Message<?>,String> exchangeNameFunction)
public S exchangeNameExpression(Expression exchangeNameExpression)
public S confirmNackChannel(MessageChannel nackChannel)
public S confirmCorrelationExpression(String confirmCorrelationExpression)
public S confirmCorrelationFunction(java.util.function.Function<Message<?>,Object> confirmCorrelationFunction)
public S confirmCorrelationExpression(Expression confirmCorrelationExpression)