public class ExtendedMessageListenerContainer
extends org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
Constructor and Description |
---|
ExtendedMessageListenerContainer() |
Modifier and Type | Method and Description |
---|---|
void |
setConcurrentConsumers(int concurrentConsumers)
Sets the number of concurrent consumers in this container.
|
void |
setConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
void |
setExclusive(boolean exclusive)
Sets whether the listener container created by this factory should be exclusive.
|
createBlockingQueueConsumer, doInitialize, doShutdown, doStart, doStop, getActiveConsumerCount, handleStartupFailure, initializeConsumers, invokeListener, isChannelLocallyTransacted, setAdviceChain, setDefaultRequeueRejected, setMessagePropertiesConverter, setPrefetchCount, setReceiveTimeout, setRecoveryInterval, setShutdownTimeout, setTaskExecutor, setTransactionAttribute, setTransactionManager, setTxSize, sharedConnectionEnabled, validateConfiguration
afterPropertiesSet, checkMessageListener, destroy, doInvokeListener, doInvokeListener, executeListener, getAcknowledgeMode, getBeanName, getMessageListener, getPhase, getQueueNames, getRequiredQueueNames, handleListenerException, initialize, invokeErrorHandler, isActive, isAutoStartup, isExposeListenerChannel, isRunning, setAcknowledgeMode, setAutoStartup, setBeanName, setErrorHandler, setExposeListenerChannel, setMessageListener, setPhase, setQueueNames, setQueues, shutdown, start, stop, stop, wrapToListenerExecutionFailedExceptionIfNeeded
public void setConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
setConnectionFactory
in class org.springframework.amqp.rabbit.connection.RabbitAccessor
public void setExclusive(boolean exclusive)
exclusive
- Whether the created container should be an exclusive listenerpublic void setConcurrentConsumers(int concurrentConsumers)
setConcurrentConsumers
in class org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
concurrentConsumers
- The number of consumers to register on the queueCopyright © 2010-2013. All Rights Reserved.