org.springframework.integration.dsl.amqp

Class AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S>>

java.lang.Object

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

org.springframework.integration.dsl.channel.MessageChannelSpec<S,org.springframework.integration.amqp.channel.AbstractAmqpChannel>

org.springframework.integration.dsl.amqp.AmqpPollableMessageChannelSpec<S>

org.springframework.integration.dsl.amqp.AmqpMessageChannelSpec<S>

Type Parameters:

S - the target AmqpMessageChannelSpec implementation type.

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<org.springframework.integration.amqp.channel.AbstractAmqpChannel>, ComponentsRegistration

Direct Known Subclasses:

AmqpPublishSubscribeMessageChannelSpec

public class AmqpMessageChannelSpec<S extends AmqpMessageChannelSpec<S>>
extends AmqpPollableMessageChannelSpec<S>

An AmqpPollableMessageChannelSpec for a message-driven PointToPointSubscribableAmqpChannel.

Author:

Artem Bilan, Gary Russell

Field Summary

Fields inherited from class org.springframework.integration.dsl.amqp.AmqpPollableMessageChannelSpec

amqpChannelFactoryBean

Fields inherited from class org.springframework.integration.dsl.channel.MessageChannelSpec

channel

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

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
S	acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
S	advice(org.aopalliance.aop.Advice... advice)
S	autoStartup(boolean autoStartup)
S	concurrentConsumers(int concurrentConsumers)
protected org.springframework.integration.amqp.channel.AbstractAmqpChannel	doGet()
S	errorHandler(org.springframework.util.ErrorHandler errorHandler)
S	exposeListenerChannel(boolean exposeListenerChannel)
S	maxSubscribers(int maxSubscribers)
S	phase(int phase)
S	prefetchCount(int prefetchCount)
S	receiveTimeout(long receiveTimeout)
S	recoveryInterval(long recoveryInterval)
S	shutdownTimeout(long shutdownTimeout)
S	taskExecutor(java.util.concurrent.Executor taskExecutor) Configure an Executor used to invoke the message listener.
S	transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) Configure a TransactionAttribute to be used with the transactionManager(PlatformTransactionManager).
S	transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) Configure a PlatformTransactionManager; used to synchronize the rabbit transaction with some other transaction(s).
S	txSize(int txSize) Configure the txSize.

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

amqpMessageConverter, channelTransacted, defaultDeliveryMode, encoding, extractPayload, id, inboundHeaderMapper, messagePropertiesConverter, outboundHeaderMapper, queueName, templateChannelTransacted

Methods inherited from class org.springframework.integration.dsl.channel.MessageChannelSpec

datatype, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTap

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

_this, 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

maxSubscribers

public S maxSubscribers(int maxSubscribers)

Parameters:

maxSubscribers - the maxSubscribers.

Returns:

the spec.

See Also:

PointToPointSubscribableAmqpChannel.setMaxSubscribers(int)

acknowledgeMode

public S acknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)

Parameters:

acknowledgeMode - the acknowledgeMode.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode)

advice

public S advice(org.aopalliance.aop.Advice... advice)

Parameters:

advice - the advice.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setAdviceChain(Advice[])

autoStartup

public S autoStartup(boolean autoStartup)

Parameters:

autoStartup - the autoStartup.

Returns:

the spec.

See Also:

SmartLifecycle

concurrentConsumers

public S concurrentConsumers(int concurrentConsumers)

Parameters:

concurrentConsumers - the concurrentConsumers

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setConcurrentConsumers(int)

errorHandler

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

Parameters:

errorHandler - the errorHandler.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)

exposeListenerChannel

public S exposeListenerChannel(boolean exposeListenerChannel)

Parameters:

exposeListenerChannel - the exposeListenerChannel.

Returns:

the spec.

See Also:

AbstractMessageListenerContainer.setExposeListenerChannel(boolean)

phase

public S phase(int phase)

Parameters:

phase - the phase.

Returns:

the spec.

See Also:

SmartLifecycle

prefetchCount

public S prefetchCount(int prefetchCount)

Parameters:

prefetchCount - the prefetchCount.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setPrefetchCount(int)

receiveTimeout

public S receiveTimeout(long receiveTimeout)

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setReceiveTimeout(long)

recoveryInterval

public S recoveryInterval(long recoveryInterval)

Parameters:

recoveryInterval - the recoveryInterval

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setRecoveryInterval(long)

shutdownTimeout

public S shutdownTimeout(long shutdownTimeout)

Parameters:

shutdownTimeout - the shutdownTimeout.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setShutdownTimeout(long)

taskExecutor

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

Configure an Executor used to invoke the message listener.

Parameters:

taskExecutor - the taskExecutor.

Returns:

the spec.

transactionAttribute

public S transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)

Configure a TransactionAttribute to be used with the transactionManager(PlatformTransactionManager).

Parameters:

transactionAttribute - the transactionAttribute.

Returns:

the spec.

transactionManager

public S 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.

txSize

public S txSize(int txSize)

Configure the txSize.

Parameters:

txSize - the txSize.

Returns:

the spec.

See Also:

SimpleMessageListenerContainer.setTxSize(int)

doGet

protected org.springframework.integration.amqp.channel.AbstractAmqpChannel doGet()

Overrides:

doGet in class AmqpPollableMessageChannelSpec<S extends AmqpMessageChannelSpec<S>>