public class AmqpInboundPolledChannelAdapterSpec extends MessageSourceSpec<AmqpInboundPolledChannelAdapterSpec,AmqpMessageSource>
PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| Modifier | Constructor and Description |
|---|---|
protected |
AmqpInboundPolledChannelAdapterSpec(ConnectionFactory connectionFactory,
AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory,
String queue) |
protected |
AmqpInboundPolledChannelAdapterSpec(ConnectionFactory connectionFactory,
String queue) |
| Modifier and Type | Method and Description |
|---|---|
AmqpInboundPolledChannelAdapterSpec |
headerMapper(AmqpHeaderMapper headerMapper) |
AmqpInboundPolledChannelAdapterSpec |
messageConverter(MessageConverter messageConverter) |
AmqpInboundPolledChannelAdapterSpec |
propertiesConverter(MessagePropertiesConverter propertiesConverter) |
AmqpInboundPolledChannelAdapterSpec |
rawMessageHeader(boolean rawMessageHeader) |
AmqpInboundPolledChannelAdapterSpec |
transacted(boolean transacted) |
messageHeaders_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonprotected AmqpInboundPolledChannelAdapterSpec(ConnectionFactory connectionFactory, String queue)
protected AmqpInboundPolledChannelAdapterSpec(ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, String queue)
public AmqpInboundPolledChannelAdapterSpec transacted(boolean transacted)
public AmqpInboundPolledChannelAdapterSpec propertiesConverter(MessagePropertiesConverter propertiesConverter)
public AmqpInboundPolledChannelAdapterSpec headerMapper(AmqpHeaderMapper headerMapper)
public AmqpInboundPolledChannelAdapterSpec messageConverter(MessageConverter messageConverter)
public AmqpInboundPolledChannelAdapterSpec rawMessageHeader(boolean rawMessageHeader)