S
- the target AmqpBaseInboundGatewaySpec
implementation type.public class AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>> extends MessagingGatewaySpec<S,AmqpInboundGateway>
MessagingGatewaySpec
implementation for AmqpInboundGateway
endpoint options.
Doesn't allow to specify listenerContainer
options.AmqpInboundGateway
logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
S |
defaultReplyTo(java.lang.String defaultReplyTo)
The
defaultReplyTo address with the form
(exchange)/(routingKey) |
S |
headerMapper(AmqpHeaderMapper headerMapper)
Configure the gateway's
AmqpHeaderMapper ; defaults to
DefaultAmqpHeaderMapper . |
S |
mappedReplyHeaders(java.lang.String... headers)
Only applies if the default header mapper is used.
|
S |
mappedRequestHeaders(java.lang.String... headers)
Only applies if the default header mapper is used.
|
S |
messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
Configure the gateway's
MessageConverter ;
defaults to SimpleMessageConverter . |
S |
recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
Set a
RecoveryCallback when using retry within the adapter. |
S |
retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
Set a
RetryTemplate to use for retrying a message delivery within the
adapter. |
autoStartup, errorChannel, errorChannel, id, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout, shouldTrack
_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType
public S messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
MessageConverter
;
defaults to SimpleMessageConverter
.messageConverter
- the messageConverter.AmqpInboundGateway.setMessageConverter(org.springframework.amqp.support.converter.MessageConverter)
public S headerMapper(AmqpHeaderMapper headerMapper)
AmqpHeaderMapper
; defaults to
DefaultAmqpHeaderMapper
.headerMapper
- the headerMapper.AmqpInboundGateway.setHeaderMapper(AmqpHeaderMapper)
public S mappedRequestHeaders(java.lang.String... headers)
headers
- the headers.AbstractHeaderMapper.setRequestHeaderNames(String[])
public S mappedReplyHeaders(java.lang.String... headers)
headers
- the headers.AbstractHeaderMapper.setReplyHeaderNames(String[])
public S defaultReplyTo(java.lang.String defaultReplyTo)
defaultReplyTo
address with the form
(exchange)/(routingKey)or
(queueName)if the request message doesn't have a
replyTo
property.
The second form uses the default exchange ("") and the queue name as
the routing key.defaultReplyTo
- the default replyTo
address to use.AmqpInboundGateway.setDefaultReplyTo(java.lang.String)
public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
RetryTemplate
to use for retrying a message delivery within the
adapter.retryTemplate
- the template.AmqpInboundGateway.setRetryTemplate(RetryTemplate)
public S recoveryCallback(org.springframework.retry.RecoveryCallback<?> recoveryCallback)
RecoveryCallback
when using retry within the adapter.recoveryCallback
- the callback.AmqpInboundGateway.setRecoveryCallback(RecoveryCallback)