public class AmqpChannelFactoryBean extends org.springframework.beans.factory.config.AbstractFactoryBean<AbstractAmqpChannel> implements org.springframework.context.SmartLifecycle, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.BeanNameAware
| Constructor and Description |
|---|
AmqpChannelFactoryBean() |
AmqpChannelFactoryBean(boolean messageDriven) |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractAmqpChannel |
createInstance() |
protected void |
destroyInstance(AbstractAmqpChannel instance) |
java.lang.Class<?> |
getObjectType() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode) |
void |
setAdviceChain(org.aopalliance.aop.Advice[] adviceChain) |
void |
setAmqpAdmin(org.springframework.amqp.core.AmqpAdmin amqpAdmin)
This is an optional reference to an AmqpAdmin to use when
declaring a Queue implicitly for a PollableAmqpChannel.
|
void |
setAutoStartup(boolean autoStartup) |
void |
setBeanName(java.lang.String name) |
void |
setChannelTransacted(boolean channelTransacted) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
void |
setEncoding(java.lang.String encoding) |
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler) |
void |
setExchange(org.springframework.amqp.core.FanoutExchange exchange)
Set the FanoutExchange to use.
|
void |
setExposeListenerChannel(boolean exposeListenerChannel) |
void |
setInterceptors(java.util.List<org.springframework.messaging.support.ChannelInterceptor> interceptors) |
void |
setMaxSubscribers(int maxSubscribers) |
void |
setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) |
void |
setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter) |
void |
setPhase(int phase) |
void |
setPrefetchCount(int prefetchCount) |
void |
setPubSub(boolean pubSub) |
void |
setQueueName(java.lang.String queueName)
Set the Queue name to use.
|
void |
setReceiveTimeout(long receiveTimeout) |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setShutdownTimeout(long shutdownTimeout) |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor) |
void |
setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
void |
setTxSize(int txSize) |
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonpublic AmqpChannelFactoryBean()
public AmqpChannelFactoryBean(boolean messageDriven)
public void setBeanName(java.lang.String name)
setBeanName in interface org.springframework.beans.factory.BeanNameAwarepublic void setInterceptors(java.util.List<org.springframework.messaging.support.ChannelInterceptor> interceptors)
public void setAmqpAdmin(org.springframework.amqp.core.AmqpAdmin amqpAdmin)
public void setExchange(org.springframework.amqp.core.FanoutExchange exchange)
public void setQueueName(java.lang.String queueName)
public void setEncoding(java.lang.String encoding)
public void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
public void setChannelTransacted(boolean channelTransacted)
public void setConnectionFactory(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public void setMessagePropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter messagePropertiesConverter)
public void setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
public void setAdviceChain(org.aopalliance.aop.Advice[] adviceChain)
public void setAutoStartup(boolean autoStartup)
public void setConcurrentConsumers(int concurrentConsumers)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public void setExposeListenerChannel(boolean exposeListenerChannel)
public void setPhase(int phase)
public void setPrefetchCount(int prefetchCount)
public void setPubSub(boolean pubSub)
public void setReceiveTimeout(long receiveTimeout)
public void setRecoveryInterval(long recoveryInterval)
public void setShutdownTimeout(long shutdownTimeout)
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public void setTransactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public void setTxSize(int txSize)
public void setMaxSubscribers(int maxSubscribers)
public java.lang.Class<?> getObjectType()
getObjectType in interface org.springframework.beans.factory.FactoryBean<AbstractAmqpChannel>getObjectType in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractAmqpChannel>protected AbstractAmqpChannel createInstance() throws java.lang.Exception
createInstance in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractAmqpChannel>java.lang.Exceptionpublic boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic int getPhase()
getPhase in interface org.springframework.context.Phasedpublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecycleprotected void destroyInstance(AbstractAmqpChannel instance) throws java.lang.Exception
destroyInstance in class org.springframework.beans.factory.config.AbstractFactoryBean<AbstractAmqpChannel>java.lang.Exception