S - the target AmqpBaseInboundChannelAdapterSpec implementation type.public class AmqpBaseInboundChannelAdapterSpec<S extends AmqpBaseInboundChannelAdapterSpec<S>> extends MessageProducerSpec<S,org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter>
MessageProducerSpec implementation for a AmqpInboundChannelAdapter.id, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
S |
headerMapper(org.springframework.integration.amqp.support.AmqpHeaderMapper headerMapper)
Configure the adapter's
AmqpHeaderMapper;
defaults to DefaultAmqpHeaderMapper. |
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 adapter's
MessageConverter;
defaults to SimpleMessageConverter. |
autoStartup, errorChannel, errorChannel, id, outputChannel, outputChannel, phase_this, doGet, get, getId, getObject, getObjectType, isSingletonpublic S messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
MessageConverter;
defaults to SimpleMessageConverter.messageConverter - the messageConverter.AmqpInboundChannelAdapter.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[])