org.springframework.integration.amqp.dsl

Class AmqpInboundChannelAdapterSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,P>

org.springframework.integration.dsl.MessageProducerSpec<S,AmqpInboundChannelAdapter>

org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec<AmqpInboundChannelAdapterSpec>

org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSpec

All Implemented Interfaces:

FactoryBean<AmqpInboundChannelAdapter>, ComponentsRegistration

public class AmqpInboundChannelAdapterSpec
extends AmqpBaseInboundChannelAdapterSpec<AmqpInboundChannelAdapterSpec>
implements ComponentsRegistration

A MessageProducerSpec for AmqpInboundChannelAdapters.

Since:

5.0

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
AmqpInboundChannelAdapterSpec	acknowledgeMode(AcknowledgeMode acknowledgeMode)
AmqpInboundChannelAdapterSpec	addQueueNames(String... queueName)
AmqpInboundChannelAdapterSpec	addQueues(Queue... queues)
AmqpInboundChannelAdapterSpec	adviceChain(Advice... adviceChain)
AmqpInboundChannelAdapterSpec	channelTransacted(boolean transactional)
AmqpInboundChannelAdapterSpec	concurrentConsumers(int concurrentConsumers)
AmqpInboundChannelAdapterSpec	consecutiveActiveTrigger(int consecutiveActiveTrigger)
AmqpInboundChannelAdapterSpec	consecutiveIdleTrigger(int consecutiveIdleTrigger)
AmqpInboundChannelAdapterSpec	defaultRequeueRejected(boolean defaultRequeueRejected)
AmqpInboundChannelAdapterSpec	errorHandler(ErrorHandler errorHandler)
AmqpInboundChannelAdapterSpec	exclusive(boolean exclusive)
Collection<Object>	getComponentsToRegister()
AmqpInboundChannelAdapterSpec	maxConcurrentConsumers(int maxConcurrentConsumers)
AmqpInboundChannelAdapterSpec	prefetchCount(int prefetchCount)
AmqpInboundChannelAdapterSpec	receiveTimeout(long receiveTimeout)
AmqpInboundChannelAdapterSpec	recoveryInterval(long recoveryInterval)
AmqpInboundChannelAdapterSpec	shutdownTimeout(long shutdownTimeout)
AmqpInboundChannelAdapterSpec	startConsumerMinInterval(long startConsumerMinInterval)
AmqpInboundChannelAdapterSpec	stopConsumerMinInterval(long stopConsumerMinInterval)
AmqpInboundChannelAdapterSpec	taskExecutor(Executor taskExecutor) Configure an Executor used to invoke the message listener.
AmqpInboundChannelAdapterSpec	transactionManager(PlatformTransactionManager transactionManager) Configure a PlatformTransactionManager; used to synchronize the rabbit transaction with some other transaction(s).
AmqpInboundChannelAdapterSpec	txSize(int txSize)

Methods inherited from class org.springframework.integration.amqp.dsl.AmqpBaseInboundChannelAdapterSpec

headerMapper, mappedRequestHeaders, messageConverter

Methods inherited from class org.springframework.integration.dsl.MessageProducerSpec

autoStartup, errorChannel, errorChannel, id, outputChannel, outputChannel, phase

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, doGet, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

acknowledgeMode

public AmqpInboundChannelAdapterSpec acknowledgeMode(AcknowledgeMode acknowledgeMode)

Parameters:

acknowledgeMode - the acknowledgeMode.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)

addQueueNames

public AmqpInboundChannelAdapterSpec addQueueNames(String... queueName)

Parameters:

queueName - a vararg list of queue names to add.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.addQueueNames(String...)

addQueues

public AmqpInboundChannelAdapterSpec addQueues(Queue... queues)

Parameters:

queues - a vararg list of queues to add.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.addQueueNames(String...)

errorHandler

public AmqpInboundChannelAdapterSpec errorHandler(ErrorHandler errorHandler)

Parameters:

errorHandler - the errorHandler.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)

channelTransacted

public AmqpInboundChannelAdapterSpec channelTransacted(boolean transactional)

Parameters:

transactional - true for transactional channels.

Returns:

the spec.

See Also:

RabbitAccessor.setChannelTransacted(boolean)

adviceChain

public AmqpInboundChannelAdapterSpec adviceChain(Advice... adviceChain)

Parameters:

adviceChain - the adviceChain.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setAdviceChain(Advice[])

recoveryInterval

public AmqpInboundChannelAdapterSpec recoveryInterval(long recoveryInterval)

Parameters:

recoveryInterval - the recoveryInterval

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setRecoveryInterval(long)

concurrentConsumers

public AmqpInboundChannelAdapterSpec concurrentConsumers(int concurrentConsumers)

Parameters:

concurrentConsumers - the concurrentConsumers

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setConcurrentConsumers(int)

maxConcurrentConsumers

public AmqpInboundChannelAdapterSpec maxConcurrentConsumers(int maxConcurrentConsumers)

Parameters:

maxConcurrentConsumers - the maxConcurrentConsumers.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)

exclusive

public AmqpInboundChannelAdapterSpec exclusive(boolean exclusive)

Parameters:

exclusive - true for exclusive.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setExclusive(boolean)

startConsumerMinInterval

public AmqpInboundChannelAdapterSpec startConsumerMinInterval(long startConsumerMinInterval)

Parameters:

startConsumerMinInterval - the startConsumerMinInterval

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setStartConsumerMinInterval(long)

stopConsumerMinInterval

public AmqpInboundChannelAdapterSpec stopConsumerMinInterval(long stopConsumerMinInterval)

Parameters:

stopConsumerMinInterval - the stopConsumerMinInterval.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setStopConsumerMinInterval(long)

consecutiveActiveTrigger

public AmqpInboundChannelAdapterSpec consecutiveActiveTrigger(int consecutiveActiveTrigger)

Parameters:

consecutiveActiveTrigger - the consecutiveActiveTrigger.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)

consecutiveIdleTrigger

public AmqpInboundChannelAdapterSpec consecutiveIdleTrigger(int consecutiveIdleTrigger)

Parameters:

consecutiveIdleTrigger - the consecutiveIdleTrigger.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)

receiveTimeout

public AmqpInboundChannelAdapterSpec receiveTimeout(long receiveTimeout)

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setReceiveTimeout(long)

shutdownTimeout

public AmqpInboundChannelAdapterSpec shutdownTimeout(long shutdownTimeout)

Parameters:

shutdownTimeout - the shutdownTimeout.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setShutdownTimeout(long)

taskExecutor

public AmqpInboundChannelAdapterSpec taskExecutor(Executor taskExecutor)

Configure an Executor used to invoke the message listener.

Parameters:

taskExecutor - the taskExecutor.

Returns:

the spec.

prefetchCount

public AmqpInboundChannelAdapterSpec prefetchCount(int prefetchCount)

Parameters:

prefetchCount - the prefetchCount.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setPrefetchCount(int)

txSize

public AmqpInboundChannelAdapterSpec txSize(int txSize)

Parameters:

txSize - the txSize.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setTxSize(int)

transactionManager

public AmqpInboundChannelAdapterSpec transactionManager(PlatformTransactionManager transactionManager)

Configure a PlatformTransactionManager; used to synchronize the rabbit transaction with some other transaction(s).

Parameters:

transactionManager - the transactionManager.

Returns:

the spec.

defaultRequeueRejected

public AmqpInboundChannelAdapterSpec defaultRequeueRejected(boolean defaultRequeueRejected)

Parameters:

defaultRequeueRejected - the defaultRequeueRejected.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setDefaultRequeueRejected(boolean)

getComponentsToRegister

public Collection<Object> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration