S - the target AmqpBaseInboundGatewaySpec implementation type.public class AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>> extends MessagingGatewaySpec<S,org.springframework.integration.amqp.inbound.AmqpInboundGateway>
MessagingGatewaySpec implementation for AmqpInboundGateway endpoint options.
Doesn't allow to specify listenerContainer options.AmqpInboundGatewayid, 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(org.springframework.integration.amqp.support.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. |
autoStartup, errorChannel, errorChannel, id, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout_this, doGet, get, getId, getObject, getObjectType, isSingletonpublic 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(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)
AmqpHeaderMapper; defaults to
DefaultAmqpHeaderMapper.headerMapper - the headerMapper.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)