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 AbstractAmqpOutboundEndpoint
s.Modifier and Type | Field and Description |
---|---|
protected DefaultAmqpHeaderMapper |
headerMapper |
logger, PARSER, target
Constructor and Description |
---|
AmqpBaseOutboundEndpointSpec() |
Modifier and Type | Method and Description |
---|---|
S |
confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel)
Set the channel to which acks are send (publisher confirms).
|
S |
confirmCorrelationExpression(org.springframework.expression.Expression confirmCorrelationExpression)
Set a SpEL expression to evaluate confirm correlation at runtime.
|
S |
confirmCorrelationExpression(java.lang.String confirmCorrelationExpression)
Set a SpEL expression to evaluate confirm correlation at runtime.
|
S |
confirmCorrelationFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.Object> confirmCorrelationFunction)
Set a
Function to evaluate confirm correlation at runtime. |
S |
confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)
Set the channel to which nacks are send (publisher confirms).
|
S |
defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)
Set the default delivery mode.
|
S |
delay(int delay)
Set the value to set in the
x-delay header when using the
RabbitMQ delayed message exchange plugin. |
S |
delayExpression(org.springframework.expression.Expression delayExpression)
Set the SpEL expression to calculate the
x-delay header when using the
RabbitMQ delayed message exchange plugin. |
S |
delayExpression(java.lang.String delayExpression)
Set the SpEL expression to calculate the
x-delay header when using the
RabbitMQ delayed message exchange plugin. |
S |
delayFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.Integer> delayFunction)
Set the function to calculate the
x-delay header when using the
RabbitMQ delayed message exchange plugin. |
S |
errorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)
Set the error message strategy to use for returned (or negatively confirmed)
messages.
|
S |
exchangeName(java.lang.String exchangeName)
Configure an AMQP exchange name for sending messages.
|
S |
exchangeNameExpression(org.springframework.expression.Expression exchangeNameExpression)
Configure a SpEL expression to evaluate an exchange name at runtime.
|
S |
exchangeNameExpression(java.lang.String exchangeNameExpression)
Configure a SpEL expression to evaluate an exchange name at runtime.
|
S |
exchangeNameFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> exchangeNameFunction)
Configure a
Function to evaluate an exchange name at runtime. |
S |
headerMapper(AmqpHeaderMapper headerMapper)
Set a custom
AmqpHeaderMapper for mapping request and reply headers. |
S |
headersMappedLast(boolean headersLast)
Determine whether the headers are
mapped before the message is converted, or afterwards.
|
S |
lazyConnect(boolean lazyConnect)
Set to
false to attempt to connect during endpoint start. |
S |
mappedReplyHeaders(java.lang.String... headers)
Provide the header names that should be mapped to a response
from a
MessageHeaders . |
S |
mappedRequestHeaders(java.lang.String... headers)
Provide the header names that should be mapped from a request to a
MessageHeaders . |
S |
returnChannel(org.springframework.messaging.MessageChannel returnChannel)
Set the channel to which returned messages are sent.
|
S |
routingKey(java.lang.String routingKey)
Configure an AMQP routing key for sending messages.
|
S |
routingKeyExpression(org.springframework.expression.Expression routingKeyExpression)
A SpEL expression to evaluate routing key at runtime.
|
S |
routingKeyExpression(java.lang.String routingKeyExpression)
A SpEL expression to evaluate routing key at runtime.
|
S |
routingKeyFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> routingKeyFunction)
A function to evaluate routing key at runtime.
|
_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, id
protected final DefaultAmqpHeaderMapper headerMapper
public S headerMapper(AmqpHeaderMapper headerMapper)
AmqpHeaderMapper
for mapping request and reply headers.headerMapper
- the AmqpHeaderMapper
to use.public S defaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)
defaultDeliveryMode
- the delivery mode.public S routingKey(java.lang.String routingKey)
routingKey
- the routing key to usepublic S routingKeyExpression(java.lang.String routingKeyExpression)
routingKeyExpression
- the expression to use.public S routingKeyFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> routingKeyFunction)
routingKeyFunction
- the Function
to use.public S routingKeyExpression(org.springframework.expression.Expression routingKeyExpression)
routingKeyExpression
- the expression to use.public S returnChannel(org.springframework.messaging.MessageChannel returnChannel)
returnChannel
- the channel.public S confirmAckChannel(org.springframework.messaging.MessageChannel ackChannel)
ackChannel
- the channel.public S exchangeName(java.lang.String exchangeName)
exchangeName
- the exchange name for sending messages.public S exchangeNameExpression(java.lang.String exchangeNameExpression)
exchangeNameExpression
- the expression to use.public S exchangeNameFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> exchangeNameFunction)
Function
to evaluate an exchange name at runtime.exchangeNameFunction
- the function to use.public S exchangeNameExpression(org.springframework.expression.Expression exchangeNameExpression)
exchangeNameExpression
- the expression to use.public S confirmNackChannel(org.springframework.messaging.MessageChannel nackChannel)
nackChannel
- the channel.public S confirmCorrelationExpression(java.lang.String confirmCorrelationExpression)
confirmCorrelationExpression
- the expression to use.public S confirmCorrelationFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.Object> confirmCorrelationFunction)
Function
to evaluate confirm correlation at runtime.confirmCorrelationFunction
- the function to use.public S confirmCorrelationExpression(org.springframework.expression.Expression confirmCorrelationExpression)
confirmCorrelationExpression
- the expression to use.public S mappedRequestHeaders(java.lang.String... headers)
MessageHeaders
.headers
- The request header names.public S mappedReplyHeaders(java.lang.String... headers)
MessageHeaders
.headers
- The reply header names.public S headersMappedLast(boolean headersLast)
headersLast
- true to map headers last.AbstractAmqpOutboundEndpoint.setHeadersMappedLast(boolean)
public S lazyConnect(boolean lazyConnect)
false
to attempt to connect during endpoint start.lazyConnect
- the lazyConnect to set.AbstractAmqpOutboundEndpoint.setLazyConnect(boolean)
public S delay(int delay)
x-delay
header when using the
RabbitMQ delayed message exchange plugin.delay
- the delay.AbstractAmqpOutboundEndpoint.setDelay(int)
public S delayFunction(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.Integer> delayFunction)
x-delay
header when using the
RabbitMQ delayed message exchange plugin.delayFunction
- the function to evaluate the value for the x-delay
header.delayExpression(Expression)
public S delayExpression(org.springframework.expression.Expression delayExpression)
x-delay
header when using the
RabbitMQ delayed message exchange plugin.delayExpression
- the expression.AbstractAmqpOutboundEndpoint.setDelayExpression(Expression)
public S delayExpression(java.lang.String delayExpression)
x-delay
header when using the
RabbitMQ delayed message exchange plugin.delayExpression
- the expression.AbstractAmqpOutboundEndpoint.setDelayExpressionString(String)
public S errorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)
errorMessageStrategy
- the strategy.AbstractAmqpOutboundEndpoint.setErrorMessageStrategy(ErrorMessageStrategy)