public class AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S>> extends MessageChannelSpec<S,org.springframework.integration.amqp.channel.AbstractAmqpChannel>
MessageChannelSpec
for a AbstractAmqpChannel
s.Modifier and Type | Field and Description |
---|---|
protected org.springframework.integration.amqp.config.AmqpChannelFactoryBean |
amqpChannelFactoryBean |
channel
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
S |
amqpMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) |
S |
channelTransacted(boolean channelTransacted)
Configure
channelTransacted on both the
RabbitTemplate (for sends) and
SimpleMessageListenerContainer
(for receives) when using Spring Integration 4.0. |
protected org.springframework.integration.amqp.channel.AbstractAmqpChannel |
doGet() |
S |
encoding(java.lang.String encoding) |
protected S |
id(java.lang.String id)
Configure the component identifier.
|
S |
messagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)
Configure
messagePropertiesConverter on both the
RabbitTemplate (for sends) and
SimpleMessageListenerContainer
(for receives). |
S |
queueName(java.lang.String queueName)
Also implicitly sets the
id(String) (if not explicitly set). |
S |
templateChannelTransacted(boolean channelTransacted)
Configure
channelTransacted on the
RabbitTemplate used when sending
messages to the channel. |
datatype, interceptor, messageConverter
_this, get, getId
protected final org.springframework.integration.amqp.config.AmqpChannelFactoryBean amqpChannelFactoryBean
protected S id(java.lang.String id)
IntegrationComponentSpec
beanName
to register the
bean in the application context for this component.id
in class MessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S>,org.springframework.integration.amqp.channel.AbstractAmqpChannel>
id
- the id.public S queueName(java.lang.String queueName)
id(String)
(if not explicitly set).queueName
- the queueName.AmqpChannelFactoryBean.setQueueName(String)
public S encoding(java.lang.String encoding)
encoding
- the encoding.RabbitTemplate.setEncoding(String)
public S amqpMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
messageConverter
- the messageConverter.RabbitTemplate.setMessageConverter(MessageConverter)
public S channelTransacted(boolean channelTransacted)
channelTransacted
on both the
RabbitTemplate
(for sends) and
SimpleMessageListenerContainer
(for receives) when using Spring Integration 4.0. When using Spring Integration
4.1, only the container is configured. See templateChannelTransacted(boolean)
.channelTransacted
- the channelTransacted.RabbitAccessor.setChannelTransacted(boolean)
,
RabbitAccessor.setChannelTransacted(boolean)
public S templateChannelTransacted(boolean channelTransacted)
channelTransacted
on the
RabbitTemplate
used when sending
messages to the channel. Only applies when Spring Integration 4.1 or greater is
being used. Otherwise, see channelTransacted(boolean)
.channelTransacted
- the channelTransacted.RabbitAccessor.setChannelTransacted(boolean)
public S messagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)
messagePropertiesConverter
on both the
RabbitTemplate
(for sends) and
SimpleMessageListenerContainer
(for receives).messagePropertiesConverter
- the messagePropertiesConverter.RabbitTemplate.setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter)
,
SimpleMessageListenerContainer.setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter)
protected org.springframework.integration.amqp.channel.AbstractAmqpChannel doGet()
doGet
in class MessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S>,org.springframework.integration.amqp.channel.AbstractAmqpChannel>