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 org.springframework.integration.dsl.MessageHandlerSpec<S,E>
MessageHandlerSpec for AbstractAmqpOutboundEndpoints.| Modifier and Type | Field and Description |
|---|---|
protected DefaultAmqpHeaderMapper |
headerMapper |
| 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(java.util.function.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(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> exchangeNameFunction) |
S |
headerMapper(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(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> routingKeyFunction) |
protected final DefaultAmqpHeaderMapper headerMapper
public S headerMapper(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(java.util.function.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(java.util.function.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(java.util.function.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)