Class AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<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>
org.springframework.integration.amqp.dsl.AmqpMessageChannelSpec<S,T>
- Type Parameters:
S- the targetAmqpMessageChannelSpecimplementation type.T- the target channel 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:
AmqpPublishSubscribeMessageChannelSpec
public class AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>,T extends AbstractAmqpChannel>
extends AmqpPollableMessageChannelSpec<S,T>
An
AmqpPollableMessageChannelSpec for a message-driven
PointToPointSubscribableAmqpChannel.- Since:
- 5.0
-
Field Summary
FieldsFields inherited from class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec
amqpChannelFactoryBeanFields inherited from class org.springframework.integration.dsl.MessageChannelSpec
channelFields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, targetFields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
loggerFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedAmqpMessageChannelSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) -
Method Summary
Modifier and TypeMethodDescriptionacknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode) advice(org.aopalliance.aop.Advice... advice) autoStartup(boolean autoStartup) batchSize(int batchSize) Configure the batch size.concurrentConsumers(int concurrentConsumers) protected TdoGet()errorHandler(org.springframework.util.ErrorHandler errorHandler) exposeListenerChannel(boolean exposeListenerChannel) maxSubscribers(int maxSubscribers) phase(int phase) prefetchCount(int prefetchCount) receiveTimeout(long receiveTimeout) recoveryInterval(long recoveryInterval) shutdownTimeout(long shutdownTimeout) taskExecutor(Executor taskExecutor) Configure anExecutorused to invoke the message listener.transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) Configure aTransactionAttributeto be used with thetransactionManager(PlatformTransactionManager).transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) Configure aPlatformTransactionManager; used to synchronize the rabbit transaction with some other transaction(s).Methods inherited from class org.springframework.integration.amqp.dsl.AmqpPollableMessageChannelSpec
amqpMessageConverter, channelTransacted, defaultDeliveryMode, encoding, extractPayload, headersMappedLast, id, inboundHeaderMapper, messagePropertiesConverter, outboundHeaderMapper, queueName, templateChannelTransactedMethods 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, stopMethods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Field Details
-
adviceChain
-
-
Constructor Details
-
AmqpMessageChannelSpec
protected AmqpMessageChannelSpec(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
-
-
Method Details
-
maxSubscribers
- Parameters:
maxSubscribers- the maxSubscribers.- Returns:
- the spec.
- See Also:
-
AbstractSubscribableAmqpChannel.setMaxSubscribers(int)
-
acknowledgeMode
- Parameters:
acknowledgeMode- the acknowledgeMode.- Returns:
- the spec.
- See Also:
-
AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)
-
advice
- Parameters:
advice- the advice.- Returns:
- the spec.
- See Also:
-
AbstractMessageListenerContainer.setAdviceChain(Advice[])
-
autoStartup
- Parameters:
autoStartup- the autoStartup.- Returns:
- the spec.
- See Also:
-
SmartLifecycle
-
concurrentConsumers
- Parameters:
concurrentConsumers- the concurrentConsumers- Returns:
- the spec.
- See Also:
-
SimpleMessageListenerContainer.setConcurrentConsumers(int)
-
errorHandler
- Parameters:
errorHandler- the errorHandler.- Returns:
- the spec.
- See Also:
-
AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)
-
exposeListenerChannel
- Parameters:
exposeListenerChannel- the exposeListenerChannel.- Returns:
- the spec.
- See Also:
-
AbstractMessageListenerContainer.setExposeListenerChannel(boolean)
-
phase
- Parameters:
phase- the phase.- Returns:
- the spec.
- See Also:
-
SmartLifecycle
-
prefetchCount
- Parameters:
prefetchCount- the prefetchCount.- Returns:
- the spec.
- See Also:
-
AbstractMessageListenerContainer.setPrefetchCount(int)
-
receiveTimeout
- Parameters:
receiveTimeout- the receiveTimeout- Returns:
- the spec.
- See Also:
-
SimpleMessageListenerContainer.setReceiveTimeout(long)
-
recoveryInterval
- Parameters:
recoveryInterval- the recoveryInterval- Returns:
- the spec.
- See Also:
-
AbstractMessageListenerContainer.setRecoveryInterval(long)
-
shutdownTimeout
- Parameters:
shutdownTimeout- the shutdownTimeout.- Returns:
- the spec.
- See Also:
-
AbstractMessageListenerContainer.setShutdownTimeout(long)
-
taskExecutor
Configure anExecutorused to invoke the message listener.- Parameters:
taskExecutor- the taskExecutor.- Returns:
- the spec.
-
transactionAttribute
public S transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) Configure aTransactionAttributeto be used with thetransactionManager(PlatformTransactionManager).- Parameters:
transactionAttribute- the transactionAttribute.- Returns:
- the spec.
-
transactionManager
public S transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) Configure aPlatformTransactionManager; used to synchronize the rabbit transaction with some other transaction(s).- Parameters:
transactionManager- the transactionManager.- Returns:
- the spec.
-
batchSize
Configure the batch size.- Parameters:
batchSize- the batchSize.- Returns:
- the spec.
- Since:
- 5.2
- See Also:
-
SimpleMessageListenerContainer.setBatchSize(int)
-
doGet
- Overrides:
doGetin classAmqpPollableMessageChannelSpec<S extends AmqpMessageChannelSpec<S,T>, T extends AbstractAmqpChannel>
-