org.springframework.integration.dsl.amqp

Class AmqpInboundGatewaySpec

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,G>

org.springframework.integration.dsl.core.MessagingGatewaySpec<S,org.springframework.integration.amqp.inbound.AmqpInboundGateway>

org.springframework.integration.dsl.amqp.AmqpBaseInboundGatewaySpec<AmqpInboundGatewaySpec>

org.springframework.integration.dsl.amqp.AmqpInboundGatewaySpec

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<org.springframework.integration.amqp.inbound.AmqpInboundGateway>, ComponentsRegistration

public class AmqpInboundGatewaySpec
extends AmqpBaseInboundGatewaySpec<AmqpInboundGatewaySpec>
implements ComponentsRegistration

An AmqpBaseInboundGatewaySpec implementation for a AmqpInboundGateway. Allows to provide SimpleMessageListenerContainer options.

Author:

Artem Bilan

Field Summary

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

logger, PARSER, target

Method Summary

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

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

defaultReplyTo, headerMapper, mappedReplyHeaders, mappedRequestHeaders, messageConverter

Methods inherited from class org.springframework.integration.dsl.core.MessagingGatewaySpec

autoStartup, errorChannel, errorChannel, id, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout

Methods inherited from class org.springframework.integration.dsl.core.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 AmqpInboundGatewaySpec acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)

Parameters:

acknowledgeMode - the acknowledgeMode.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)

addQueueNames

public AmqpInboundGatewaySpec addQueueNames(java.lang.String... queueName)

Parameters:

queueName - a vararg list of queue names to add.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.addQueueNames(String...)

addQueues

public AmqpInboundGatewaySpec addQueues(org.springframework.amqp.core.Queue... queues)

Parameters:

queues - a vararg list of queues to add.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.addQueueNames(String...)

errorHandler

public AmqpInboundGatewaySpec errorHandler(org.springframework.util.ErrorHandler errorHandler)

Parameters:

errorHandler - the errorHandler.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)

channelTransacted

public AmqpInboundGatewaySpec channelTransacted(boolean transactional)

Parameters:

transactional - true for transactional channels.

Returns:

the spec.

See Also:

RabbitAccessor.setChannelTransacted(boolean)

adviceChain

public AmqpInboundGatewaySpec adviceChain(org.aopalliance.aop.Advice... adviceChain)

Parameters:

adviceChain - the adviceChain.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setAdviceChain(Advice[])

recoveryInterval

public AmqpInboundGatewaySpec recoveryInterval(long recoveryInterval)

Parameters:

recoveryInterval - the recoveryInterval

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setRecoveryInterval(long)

concurrentConsumers

public AmqpInboundGatewaySpec concurrentConsumers(int concurrentConsumers)

Parameters:

concurrentConsumers - the concurrentConsumers

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setConcurrentConsumers(int)

maxConcurrentConsumers

public AmqpInboundGatewaySpec maxConcurrentConsumers(int maxConcurrentConsumers)

Parameters:

maxConcurrentConsumers - the maxConcurrentConsumers.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setMaxConcurrentConsumers(int)

exclusive

public AmqpInboundGatewaySpec exclusive(boolean exclusive)

Parameters:

exclusive - true for exclusive.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setExclusive(boolean)

startConsumerMinInterval

public AmqpInboundGatewaySpec startConsumerMinInterval(long startConsumerMinInterval)

Parameters:

startConsumerMinInterval - the startConsumerMinInterval

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setStartConsumerMinInterval(long)

stopConsumerMinInterval

public AmqpInboundGatewaySpec stopConsumerMinInterval(long stopConsumerMinInterval)

Parameters:

stopConsumerMinInterval - the stopConsumerMinInterval.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setStopConsumerMinInterval(long)

consecutiveActiveTrigger

public AmqpInboundGatewaySpec consecutiveActiveTrigger(int consecutiveActiveTrigger)

Parameters:

consecutiveActiveTrigger - the consecutiveActiveTrigger.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setConsecutiveActiveTrigger(int)

consecutiveIdleTrigger

public AmqpInboundGatewaySpec consecutiveIdleTrigger(int consecutiveIdleTrigger)

Parameters:

consecutiveIdleTrigger - the consecutiveIdleTrigger.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setConsecutiveIdleTrigger(int)

receiveTimeout

public AmqpInboundGatewaySpec receiveTimeout(long receiveTimeout)

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setReceiveTimeout(long)

shutdownTimeout

public AmqpInboundGatewaySpec shutdownTimeout(long shutdownTimeout)

Parameters:

shutdownTimeout - the shutdownTimeout.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setShutdownTimeout(long)

taskExecutor

public AmqpInboundGatewaySpec taskExecutor(java.util.concurrent.Executor taskExecutor)

Configure an Executor used to invoke the message listener.

Parameters:

taskExecutor - the taskExecutor.

Returns:

the spec.

prefetchCount

public AmqpInboundGatewaySpec prefetchCount(int prefetchCount)

Parameters:

prefetchCount - the prefetchCount.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setPrefetchCount(int)

txSize

public AmqpInboundGatewaySpec txSize(int txSize)

Parameters:

txSize - the txSize.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setTxSize(int)

transactionManager

public AmqpInboundGatewaySpec transactionManager(org.springframework.transaction.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 AmqpInboundGatewaySpec defaultRequeueRejected(boolean defaultRequeueRejected)

Parameters:

defaultRequeueRejected - the defaultRequeueRejected.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setDefaultRequeueRejected(boolean)

getComponentsToRegister

public java.util.Collection<java.lang.Object> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration