public class AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S>> extends MessageChannelSpec<S,org.springframework.integration.amqp.channel.AbstractAmqpChannel>
MessageChannelSpec for a AbstractAmqpChannels.| Modifier and Type | Field and Description |
|---|---|
protected org.springframework.integration.amqp.config.AmqpChannelFactoryBean |
amqpChannelFactoryBean |
channelid, 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, getIdprotected final org.springframework.integration.amqp.config.AmqpChannelFactoryBean amqpChannelFactoryBean
protected S id(java.lang.String id)
IntegrationComponentSpecbeanName 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>