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 |
setConsumersPerQueue(java.lang.Integer consumersPerQueue) |
void |
setDefaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode) |
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 |
setExtractPayload(java.lang.Boolean extractPayload) |
void |
setHeadersLast(boolean headersLast) |
void |
setInboundHeaderMapper(AmqpHeaderMapper inboundMapper) |
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 |
setMissingQueuesFatal(java.lang.Boolean missingQueuesFatal) |
void |
setOutboundHeaderMapper(AmqpHeaderMapper outboundMapper) |
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 |
setTemplateChannelTransacted(boolean channelTransacted) |
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)
amqpAdmin - The amqp admin.public void setExchange(org.springframework.amqp.core.FanoutExchange exchange)
exchange - The fanout exchange.public void setQueueName(java.lang.String queueName)
queueName - The queue name.public void setEncoding(java.lang.String encoding)
public void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
public void setTemplateChannelTransacted(boolean channelTransacted)
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 setConsumersPerQueue(java.lang.Integer consumersPerQueue)
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 void setMissingQueuesFatal(java.lang.Boolean missingQueuesFatal)
public void setDefaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDeliveryMode)
public void setExtractPayload(java.lang.Boolean extractPayload)
public void setOutboundHeaderMapper(AmqpHeaderMapper outboundMapper)
public void setInboundHeaderMapper(AmqpHeaderMapper inboundMapper)
public void setHeadersLast(boolean headersLast)
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.PhasedgetPhase in interface org.springframework.context.SmartLifecyclepublic 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