public class AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S>> extends MessageChannelSpec<S,org.springframework.integration.amqp.channel.AbstractAmqpChannel>
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) |
protected org.springframework.integration.amqp.channel.AbstractAmqpChannel |
doGet() |
S |
encoding(java.lang.String encoding) |
protected S |
id(java.lang.String id) |
S |
messagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter) |
S |
queueName(java.lang.String queueName) |
datatype, interceptor, messageConverter
_this, get, getId
protected final org.springframework.integration.amqp.config.AmqpChannelFactoryBean amqpChannelFactoryBean
protected S id(java.lang.String id)
id
in class MessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S>,org.springframework.integration.amqp.channel.AbstractAmqpChannel>
public S queueName(java.lang.String queueName)
public S encoding(java.lang.String encoding)
public S amqpMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
public S channelTransacted(boolean channelTransacted)
public S messagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)
protected org.springframework.integration.amqp.channel.AbstractAmqpChannel doGet()
doGet
in class MessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S>,org.springframework.integration.amqp.channel.AbstractAmqpChannel>