public class AmqpBaseInboundGatewaySpec<S extends AmqpBaseInboundGatewaySpec<S>> extends MessagingGatewaySpec<S,org.springframework.integration.amqp.inbound.AmqpInboundGateway>
MessagingGatewaySpec implementation for AmqpInboundGateway endpoint options.| Modifier and Type | Field and Description |
|---|---|
protected org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper |
headerMapper |
id, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
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, doGet, errorChannel, id, phase, replyChannel, replyMapper, replyTimeout, requestChannel, requestMapper, requestTimeout_this, get, getIdprotected final org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper headerMapper
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(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[])