|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.axonframework.eventhandling.amqp.spring.SpringAMQPConsumerConfiguration
public class SpringAMQPConsumerConfiguration
AMQPConsumerConfiguration implementation that has additional support for all Spring-specific AMQP Configuration properties. This bean allows configuration using setters, to make it easier to configure inside an application context configuration file.
Note that this class is not thread-safe and should not be used outside of the Spring Application context.
Field Summary |
---|
Fields inherited from interface org.axonframework.eventhandling.amqp.AMQPConsumerConfiguration |
---|
AMQP_CONFIG_PROPERTY |
Constructor Summary | |
---|---|
SpringAMQPConsumerConfiguration()
|
Method Summary | |
---|---|
org.springframework.amqp.core.AcknowledgeMode |
getAcknowledgeMode()
Returns the AcknowledgeMode configured in this instance, or the one provided by the default configuration if not explicitly provided. |
org.aopalliance.aop.Advice[] |
getAdviceChain()
Returns the Advice Chain configured in this instance, or the one provided by the default configuration if not explicitly provided. |
Integer |
getConcurrentConsumers()
Returns the Concurrent Consumers configured in this instance, or the one provided by the default configuration if not explicitly provided. |
org.springframework.util.ErrorHandler |
getErrorHandler()
Returns the ErrorHandler configured in this instance, or the one provided by the default configuration if not explicitly provided. |
Boolean |
getExclusive()
Indicates whether this Cluster wishes to be an exclusive consumer on a Queue. |
org.springframework.amqp.rabbit.support.MessagePropertiesConverter |
getMessagePropertiesConverter()
Returns the MessagePropertiesConverter configured in this instance, or the one provided by the default configuration if not explicitly provided. |
Integer |
getPrefetchCount()
Returns the Prefetch Count configured in this instance, or the one provided by the default configuration if not explicitly provided. |
String |
getQueueName()
Returns the Queue Name the Cluster should be connected to, or null if no explicit cluster is
configured. |
Long |
getReceiveTimeout()
Returns the Receive Timeout configured in this instance, or the one provided by the default configuration if not explicitly provided. |
Long |
getRecoveryInterval()
Returns the Recovery Interval configured in this instance, or the one provided by the default configuration if not explicitly provided. |
Long |
getShutdownTimeout()
Returns the Shutdown Timeout configured in this instance, or the one provided by the default configuration if not explicitly provided. |
Executor |
getTaskExecutor()
Returns the Task Executor configured in this instance, or the one provided by the default configuration if not explicitly provided. |
org.springframework.transaction.interceptor.TransactionAttribute |
getTransactionAttribute()
Returns the TransactionAttribute configured in this instance, or the one provided by the default configuration if not explicitly provided. |
org.springframework.transaction.PlatformTransactionManager |
getTransactionManager()
Returns the TransactionManager configured in this instance, or the one provided by the default configuration if not explicitly provided. |
Integer |
getTxSize()
Returns the Transaction Size configured in this instance, or the one provided by the default configuration if not explicitly provided. |
void |
setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
Sets the acknowledge mode to use for the cluster |
void |
setAdviceChain(org.aopalliance.aop.Advice[] adviceChain)
Sets the Advice Chain to use for the cluster. |
void |
setConcurrentConsumers(Integer concurrentConsumers)
Sets the number of concurrent consumers to use for the cluster |
void |
setDefaults(SpringAMQPConsumerConfiguration defaults)
Sets the defaults to use when this instance does not explicitly provide a configuration value. |
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
Sets the Error Handler to use for the cluster. |
void |
setExclusive(Boolean exclusive)
Sets whether the listener container created by this factory should be exclusive. |
void |
setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)
Sets the message properties converter to use for the cluster |
void |
setPrefetchCount(Integer prefetchCount)
Sets the PrefetchCount to use for the cluster. |
void |
setQueueName(String queueName)
Sets the name of the Queue that a Cluster should be connected to. |
void |
setReceiveTimeout(Long receiveTimeout)
Sets the receive timeout to use for the cluster |
void |
setRecoveryInterval(Long recoveryInterval)
Sets the Recovery Interval to use for the cluster. |
void |
setShutdownTimeout(Long shutdownTimeout)
Sets the shutdown timeout to use for the cluster |
void |
setTaskExecutor(Executor taskExecutor)
Sets the task executor to use for the cluster |
void |
setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
Sets the transaction attribute to use for the cluster |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
Sets the PlatformTransactionManager to use for the cluster. |
void |
setTxSize(Integer txSize)
Sets the Transaction Size to use for the cluster. |
static SpringAMQPConsumerConfiguration |
wrap(AMQPConsumerConfiguration configuration)
Creates a SpringAMQPConsumerConfiguration instance from the given configuration . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SpringAMQPConsumerConfiguration()
Method Detail |
---|
public static SpringAMQPConsumerConfiguration wrap(AMQPConsumerConfiguration configuration)
configuration
. If tha
configuration is already an instance of SpringAMQPConsumerConfiguration, it is returned as is. Otherwise, the
properties in the configuration are copied into a fresh instance of SpringAMQPConsumerConfiguration.
configuration
- The configuration to wrap in a SpringAMQPConsumerConfiguration
configuration
public void setDefaults(SpringAMQPConsumerConfiguration defaults)
null
for some configuration options that the previous defaults did provide a value for.
defaults
- The defaults to usepublic String getQueueName()
AMQPConsumerConfiguration
null
if no explicit cluster is
configured.
getQueueName
in interface AMQPConsumerConfiguration
null
to revert to a defaultpublic org.springframework.transaction.PlatformTransactionManager getTransactionManager()
default configuration
if not explicitly provided.
public org.springframework.util.ErrorHandler getErrorHandler()
default configuration
if not explicitly provided.
public Integer getTxSize()
default configuration
if not explicitly provided.
public Integer getPrefetchCount()
default configuration
if not explicitly provided.
getPrefetchCount
in interface AMQPConsumerConfiguration
public org.aopalliance.aop.Advice[] getAdviceChain()
default configuration
if not explicitly provided.
public Long getRecoveryInterval()
default configuration
if not explicitly provided.
public Integer getConcurrentConsumers()
default configuration
if not explicitly provided.
public Long getReceiveTimeout()
default configuration
if not explicitly provided.
public Long getShutdownTimeout()
default configuration
if not explicitly provided.
public Executor getTaskExecutor()
default configuration
if not explicitly provided.
public org.springframework.transaction.interceptor.TransactionAttribute getTransactionAttribute()
default configuration
if not explicitly provided.
public org.springframework.amqp.rabbit.support.MessagePropertiesConverter getMessagePropertiesConverter()
default configuration
if not explicitly provided.
public org.springframework.amqp.core.AcknowledgeMode getAcknowledgeMode()
default configuration
if not explicitly provided.
public Boolean getExclusive()
AMQPConsumerConfiguration
null
indicated that
no explicit preference is provided, and a default should be used.
getExclusive
in interface AMQPConsumerConfiguration
public void setQueueName(String queueName)
null
, a Queue Name is
expected to be provided by the default configuration.
queueName
- The queue name to connect the Cluster topublic void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
setChannelTransacted()
).
transactionManager
- The transaction manager to setSimpleMessageListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
errorHandler
- the Error Handler to setAbstractMessageListenerContainer.setErrorHandler(org.springframework.util.ErrorHandler)
public void setTxSize(Integer txSize)
txSize
- the transaction size to setSimpleMessageListenerContainer.setTxSize(int)
public void setPrefetchCount(Integer prefetchCount)
prefetchCount
- the prefetch count to setSimpleMessageListenerContainer.setPrefetchCount(int)
public void setAdviceChain(org.aopalliance.aop.Advice[] adviceChain)
adviceChain
- the advice chain to setSimpleMessageListenerContainer.setAdviceChain(org.aopalliance.aop.Advice[])
public void setRecoveryInterval(Long recoveryInterval)
recoveryInterval
- the recovery interval to setSimpleMessageListenerContainer.setRecoveryInterval(long)
public void setConcurrentConsumers(Integer concurrentConsumers)
concurrentConsumers
- The number of concurrent consumersSimpleMessageListenerContainer.setConcurrentConsumers(int)
public void setReceiveTimeout(Long receiveTimeout)
receiveTimeout
- The receive timeout to setSimpleMessageListenerContainer.setReceiveTimeout(long)
public void setShutdownTimeout(Long shutdownTimeout)
shutdownTimeout
- The shutdown timeout to setSimpleMessageListenerContainer.setShutdownTimeout(long)
public void setTaskExecutor(Executor taskExecutor)
taskExecutor
- The task executor to setSimpleMessageListenerContainer.setTaskExecutor(java.util.concurrent.Executor)
public void setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
transactionAttribute
- The transaction attribute to setSimpleMessageListenerContainer.setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute)
public void setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)
messagePropertiesConverter
- The message properties converter to setSimpleMessageListenerContainer.setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter)
public void setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
acknowledgeMode
- The acknowledge mode to setAbstractMessageListenerContainer.setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode)
public void setExclusive(Boolean exclusive)
exclusive
- Whether the created container should be an exclusive listener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |