S
- the target AmqpBaseOutboundEndpointSpec
implementation type.E
- the target AbstractAmqpOutboundEndpoint
implementation type.public abstract class AmqpBaseOutboundEndpointSpec<S extends AmqpBaseOutboundEndpointSpec<S,E>,E extends org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint> extends MessageHandlerSpec<S,E>
MessageHandlerSpec
for AbstractAmqpOutboundEndpoint
s.Modifier and Type | Field and Description |
---|---|
protected org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper |
headerMapper |
logger, PARSER, target
Constructor and Description |
---|
AmqpBaseOutboundEndpointSpec() |
Modifier and Type | Method and Description |
---|---|
S |
confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel) |
S |
confirmCorrelationExpression(org.springframework.expression.Expression confirmCorrelationExpression) |
S |
confirmCorrelationExpression(java.lang.String confirmCorrelationExpression) |
S |
confirmCorrelationFunction(Function<org.springframework.messaging.Message<?>,java.lang.Object> confirmCorrelationFunction) |
S |
confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel) |
S |
defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode) |
S |
exchangeName(java.lang.String exchangeName) |
S |
exchangeNameExpression(org.springframework.expression.Expression exchangeNameExpression) |
S |
exchangeNameExpression(java.lang.String exchangeNameExpression) |
S |
exchangeNameFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> exchangeNameFunction) |
S |
headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper) |
S |
mappedReplyHeaders(java.lang.String... headers) |
S |
mappedRequestHeaders(java.lang.String... headers) |
S |
returnChannel(org.springframework.messaging.MessageChannel returnChannel) |
S |
routingKey(java.lang.String routingKey) |
S |
routingKeyExpression(org.springframework.expression.Expression routingKeyExpression) |
S |
routingKeyExpression(java.lang.String routingKeyExpression) |
S |
routingKeyFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> routingKeyFunction) |
_this, doGet, get, getId, getObject, getObjectType, id, isSingleton
protected final org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper headerMapper
public S headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)
public S defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)
public S routingKey(java.lang.String routingKey)
public S routingKeyExpression(java.lang.String routingKeyExpression)
public S routingKeyFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> routingKeyFunction)
public S routingKeyExpression(org.springframework.expression.Expression routingKeyExpression)
public S returnChannel(org.springframework.messaging.MessageChannel returnChannel)
public S confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel)
public S exchangeName(java.lang.String exchangeName)
public S exchangeNameExpression(java.lang.String exchangeNameExpression)
public S exchangeNameFunction(Function<org.springframework.messaging.Message<?>,java.lang.String> exchangeNameFunction)
public S exchangeNameExpression(org.springframework.expression.Expression exchangeNameExpression)
public S confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)
public S confirmCorrelationExpression(java.lang.String confirmCorrelationExpression)
public S confirmCorrelationFunction(Function<org.springframework.messaging.Message<?>,java.lang.Object> confirmCorrelationFunction)
public S confirmCorrelationExpression(org.springframework.expression.Expression confirmCorrelationExpression)
public S mappedRequestHeaders(java.lang.String... headers)
public S mappedReplyHeaders(java.lang.String... headers)