public class AmqpChannelFactoryBean extends AbstractFactoryBean<AbstractAmqpChannel> implements SmartLifecycle, DisposableBean, BeanNameAware
logger
Constructor and Description |
---|
AmqpChannelFactoryBean() |
AmqpChannelFactoryBean(boolean messageDriven) |
Modifier and Type | Method and Description |
---|---|
protected AbstractAmqpChannel |
createInstance() |
protected void |
destroyInstance(AbstractAmqpChannel instance) |
Class<?> |
getObjectType() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAcknowledgeMode(AcknowledgeMode acknowledgeMode) |
void |
setAdviceChain(org.aopalliance.aop.Advice[] adviceChain) |
void |
setAmqpAdmin(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(String name) |
void |
setChannelTransacted(boolean channelTransacted) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setConnectionFactory(ConnectionFactory connectionFactory) |
void |
setEncoding(String encoding) |
void |
setErrorHandler(ErrorHandler errorHandler) |
void |
setExchange(FanoutExchange exchange)
Set the FanoutExchange to use.
|
void |
setExposeListenerChannel(boolean exposeListenerChannel) |
void |
setInterceptors(List<ChannelInterceptor> interceptors) |
void |
setMaxSubscribers(int maxSubscribers) |
void |
setMessageConverter(MessageConverter messageConverter) |
void |
setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter) |
void |
setPhase(int phase) |
void |
setPrefetchCount(int prefetchCount) |
void |
setPubSub(boolean pubSub) |
void |
setQueueName(String queueName)
Set the Queue name to use.
|
void |
setReceiveTimeout(long receiveTimeout) |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setShutdownTimeout(long shutdownTimeout) |
void |
setTaskExecutor(Executor taskExecutor) |
void |
setTransactionAttribute(TransactionAttribute transactionAttribute) |
void |
setTransactionManager(PlatformTransactionManager transactionManager) |
void |
setTxSize(int txSize) |
void |
start() |
void |
stop() |
void |
stop(Runnable callback) |
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy
public AmqpChannelFactoryBean()
public AmqpChannelFactoryBean(boolean messageDriven)
public void setBeanName(String name)
setBeanName
in interface BeanNameAware
public void setInterceptors(List<ChannelInterceptor> interceptors)
public void setAmqpAdmin(AmqpAdmin amqpAdmin)
amqpAdmin
- The amqp admin.public void setExchange(FanoutExchange exchange)
exchange
- The fanout exchange.public void setQueueName(String queueName)
queueName
- The queue name.public void setEncoding(String encoding)
public void setMessageConverter(MessageConverter messageConverter)
public void setChannelTransacted(boolean channelTransacted)
public void setConnectionFactory(ConnectionFactory connectionFactory)
public void setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)
public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
public void setAdviceChain(org.aopalliance.aop.Advice[] adviceChain)
public void setAutoStartup(boolean autoStartup)
public void setConcurrentConsumers(int concurrentConsumers)
public void setErrorHandler(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(Executor taskExecutor)
public void setTransactionAttribute(TransactionAttribute transactionAttribute)
public void setTransactionManager(PlatformTransactionManager transactionManager)
public void setTxSize(int txSize)
public void setMaxSubscribers(int maxSubscribers)
public Class<?> getObjectType()
getObjectType
in interface FactoryBean<AbstractAmqpChannel>
getObjectType
in class AbstractFactoryBean<AbstractAmqpChannel>
protected AbstractAmqpChannel createInstance() throws Exception
createInstance
in class AbstractFactoryBean<AbstractAmqpChannel>
Exception
public boolean isAutoStartup()
isAutoStartup
in interface SmartLifecycle
public void stop(Runnable callback)
stop
in interface SmartLifecycle
protected void destroyInstance(AbstractAmqpChannel instance) throws Exception
destroyInstance
in class AbstractFactoryBean<AbstractAmqpChannel>
Exception