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
.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, isSingleton
public 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[])