org.springframework.integration.amqp.config

Class AmqpChannelFactoryBean

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<AbstractAmqpChannel>

org.springframework.integration.amqp.config.AmqpChannelFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<AbstractAmqpChannel>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class AmqpChannelFactoryBean
extends AbstractFactoryBean<AbstractAmqpChannel>
implements SmartLifecycle, DisposableBean, BeanNameAware

If point-to-point, we send to the default exchange with the routing key equal to "[beanName]" and we declare that same Queue and register a listener if message-driven or poll explicitly otherwise. If publish-subscribe, we declare a FanoutExchange named "si.fanout.[beanName]" and we send to that without any routing key, and on the receiving side, we create an anonymous Queue that is bound to that exchange.

Since:

2.1

Author:

Mark Fisher, Gary Russell

Field Summary

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

Constructor Summary

Constructors

Constructor and Description
AmqpChannelFactoryBean()
AmqpChannelFactoryBean(boolean messageDriven)

Method Summary

Methods

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)

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.DisposableBean

destroy

Constructor Detail

AmqpChannelFactoryBean

public AmqpChannelFactoryBean()

AmqpChannelFactoryBean

public AmqpChannelFactoryBean(boolean messageDriven)

Method Detail

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

setInterceptors

public void setInterceptors(List<ChannelInterceptor> interceptors)

setAmqpAdmin

public void setAmqpAdmin(AmqpAdmin amqpAdmin)

This is an optional reference to an AmqpAdmin to use when declaring a Queue implicitly for a PollableAmqpChannel. It is not needed for the message-driven (Subscribable) channels since those are able to create a RabbitAdmin instance using the underlying listener container's ConnectionFactory.

Parameters:

amqpAdmin - The amqp admin.

setExchange

public void setExchange(FanoutExchange exchange)

Set the FanoutExchange to use. This is only relevant for publish-subscribe-channels, and even then if not provided, a FanoutExchange will be implicitly created.

Parameters:

exchange - The fanout exchange.

setQueueName

public void setQueueName(String queueName)

Set the Queue name to use. This is only relevant for point-to-point channels, even then if not provided, a Queue will be implicitly created.

Parameters:

queueName - The queue name.

setEncoding

public void setEncoding(String encoding)

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

setChannelTransacted

public void setChannelTransacted(boolean channelTransacted)

setConnectionFactory

public void setConnectionFactory(ConnectionFactory connectionFactory)

setMessagePropertiesConverter

public void setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)

setAcknowledgeMode

public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)

setAdviceChain

public void setAdviceChain(org.aopalliance.aop.Advice[] adviceChain)

setAutoStartup

public void setAutoStartup(boolean autoStartup)

setConcurrentConsumers

public void setConcurrentConsumers(int concurrentConsumers)

setErrorHandler

public void setErrorHandler(ErrorHandler errorHandler)

setExposeListenerChannel

public void setExposeListenerChannel(boolean exposeListenerChannel)

setPhase

public void setPhase(int phase)

setPrefetchCount

public void setPrefetchCount(int prefetchCount)

setPubSub

public void setPubSub(boolean pubSub)

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

setRecoveryInterval

public void setRecoveryInterval(long recoveryInterval)

setShutdownTimeout

public void setShutdownTimeout(long shutdownTimeout)

setTaskExecutor

public void setTaskExecutor(Executor taskExecutor)

setTransactionAttribute

public void setTransactionAttribute(TransactionAttribute transactionAttribute)

setTransactionManager

public void setTransactionManager(PlatformTransactionManager transactionManager)

setTxSize

public void setTxSize(int txSize)

setMaxSubscribers

public void setMaxSubscribers(int maxSubscribers)

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<AbstractAmqpChannel>

Specified by:

getObjectType in class AbstractFactoryBean<AbstractAmqpChannel>

createInstance

protected AbstractAmqpChannel createInstance()
                                      throws Exception

Specified by:

createInstance in class AbstractFactoryBean<AbstractAmqpChannel>

Throws:

Exception

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface SmartLifecycle

destroyInstance

protected void destroyInstance(AbstractAmqpChannel instance)
                        throws Exception

Overrides:

destroyInstance in class AbstractFactoryBean<AbstractAmqpChannel>

Throws:

Exception