Class AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel>
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.dsl.MessageChannelSpec<S,T>
org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec<S,T>
- Type Parameters:
S- the targetAmqpPollableMessageChannelSpecimplementation type.
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<T>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.dsl.ComponentsRegistration
- Direct Known Subclasses:
AmqpMessageChannelSpec
public class AmqpPollableMessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel>
extends org.springframework.integration.dsl.MessageChannelSpec<S,T>
A
MessageChannelSpec for a AbstractAmqpChannels.- Since:
- 5.0
-
Field Summary
Fields Modifier and Type Field Description protected AmqpChannelFactoryBeanamqpChannelFactoryBean -
Constructor Summary
Constructors Modifier Constructor Description protectedAmqpPollableMessageChannelSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) -
Method Summary
Modifier and Type Method Description SamqpMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)SchannelTransacted(boolean channelTransacted)ConfigurechannelTransactedon both theRabbitTemplate(for sends) andSimpleMessageListenerContainer(for receives) when using Spring Integration 4.0.SdefaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode mode)Configure the delivery mode for messages that don't have anAmqpHeaders.DELIVERY_MODEheader.protected TdoGet()Sencoding(java.lang.String encoding)SextractPayload(boolean extract)Configure whether normal spring-messaging to AMQP message mapping is enabled.SheadersMappedLast(boolean headersLast)protected Sid(java.lang.String id)SinboundHeaderMapper(AmqpHeaderMapper mapper)Configure the inbound header mapper to use whenextractPayload(boolean)is true.SmessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)ConfiguremessagePropertiesConverteron both theRabbitTemplate(for sends) andSimpleMessageListenerContainer(for receives).SoutboundHeaderMapper(AmqpHeaderMapper mapper)Configure the outbound header mapper to use whenextractPayload(boolean)is true.SqueueName(java.lang.String queueName)Also implicitly sets theid(String)(if not explicitly set).StemplateChannelTransacted(boolean channelTransacted)ConfigurechannelTransactedon theRabbitTemplateused when sending messages to the channel.Methods inherited from class org.springframework.integration.dsl.MessageChannelSpec
datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTapMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
-
Field Details
-
Constructor Details
-
AmqpPollableMessageChannelSpec
protected AmqpPollableMessageChannelSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
-
-
Method Details
-
id
- Overrides:
idin classorg.springframework.integration.dsl.IntegrationComponentSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel>
-
queueName
Also implicitly sets theid(String)(if not explicitly set).- Parameters:
queueName- the queueName.- Returns:
- the spec.
- See Also:
AmqpChannelFactoryBean.setQueueName(String)
-
encoding
- Parameters:
encoding- the encoding.- Returns:
- the spec.
- See Also:
RabbitTemplate.setEncoding(String)
-
amqpMessageConverter
public S amqpMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)- Parameters:
messageConverter- the messageConverter.- Returns:
- the spec.
- See Also:
RabbitTemplate.setMessageConverter(MessageConverter)
-
channelTransacted
ConfigurechannelTransactedon both theRabbitTemplate(for sends) andSimpleMessageListenerContainer(for receives) when using Spring Integration 4.0. When using Spring Integration 4.1, only the container is configured. SeetemplateChannelTransacted(boolean).- Parameters:
channelTransacted- the channelTransacted.- Returns:
- the spec.
- See Also:
RabbitAccessor.setChannelTransacted(boolean),RabbitAccessor.setChannelTransacted(boolean)
-
templateChannelTransacted
ConfigurechannelTransactedon theRabbitTemplateused when sending messages to the channel. Only applies when Spring Integration 4.1 or greater is being used. Otherwise, seechannelTransacted(boolean).- Parameters:
channelTransacted- the channelTransacted.- Returns:
- the spec.
- See Also:
RabbitAccessor.setChannelTransacted(boolean)
-
messagePropertiesConverter
public S messagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)ConfiguremessagePropertiesConverteron both theRabbitTemplate(for sends) andSimpleMessageListenerContainer(for receives).- Parameters:
messagePropertiesConverter- the messagePropertiesConverter.- Returns:
- the spec.
- See Also:
RabbitTemplate.setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter),AbstractMessageListenerContainer.setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter)
-
defaultDeliveryMode
Configure the delivery mode for messages that don't have anAmqpHeaders.DELIVERY_MODEheader. Default isMessageDeliveryMode.PERSISTENT.- Parameters:
mode- the mode.- Returns:
- the spec.
-
extractPayload
Configure whether normal spring-messaging to AMQP message mapping is enabled. Default false.- Parameters:
extract- true to enable mapping.- Returns:
- the spec.
- See Also:
outboundHeaderMapper(AmqpHeaderMapper),inboundHeaderMapper(AmqpHeaderMapper)
-
outboundHeaderMapper
Configure the outbound header mapper to use whenextractPayload(boolean)is true. Defaults to aDefaultAmqpHeaderMapper.- Parameters:
mapper- the mapper.- Returns:
- the spec.
- See Also:
extractPayload(boolean)
-
inboundHeaderMapper
Configure the inbound header mapper to use whenextractPayload(boolean)is true. Defaults to aDefaultAmqpHeaderMapper.- Parameters:
mapper- the mapper.- Returns:
- the spec.
- See Also:
extractPayload(boolean)
-
headersMappedLast
- Parameters:
headersLast- true to map headers last.- Returns:
- the spec.
- See Also:
AbstractAmqpChannel.setHeadersMappedLast(boolean)
-
doGet
- Overrides:
doGetin classorg.springframework.integration.dsl.MessageChannelSpec<S extends AmqpPollableMessageChannelSpec<S,T>,T extends AbstractAmqpChannel>
-