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, getId
protected 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[])