public class AmqpInboundPolledChannelAdapterSpec extends org.springframework.integration.dsl.MessageSourceSpec<AmqpInboundPolledChannelAdapterSpec,AmqpMessageSource>
| Modifier | Constructor and Description |
|---|---|
protected |
AmqpInboundPolledChannelAdapterSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory,
java.lang.String queue) |
protected |
AmqpInboundPolledChannelAdapterSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String queue) |
| Modifier and Type | Method and Description |
|---|---|
AmqpInboundPolledChannelAdapterSpec |
headerMapper(AmqpHeaderMapper headerMapper) |
AmqpInboundPolledChannelAdapterSpec |
messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) |
AmqpInboundPolledChannelAdapterSpec |
propertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter propertiesConverter) |
AmqpInboundPolledChannelAdapterSpec |
rawMessageHeader(boolean rawMessageHeader) |
AmqpInboundPolledChannelAdapterSpec |
transacted(boolean transacted) |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopprotected AmqpInboundPolledChannelAdapterSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String queue)
protected AmqpInboundPolledChannelAdapterSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory,
java.lang.String queue)
public AmqpInboundPolledChannelAdapterSpec transacted(boolean transacted)
public AmqpInboundPolledChannelAdapterSpec propertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter propertiesConverter)
public AmqpInboundPolledChannelAdapterSpec headerMapper(AmqpHeaderMapper headerMapper)
public AmqpInboundPolledChannelAdapterSpec messageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
public AmqpInboundPolledChannelAdapterSpec rawMessageHeader(boolean rawMessageHeader)