Class SingleAmqpConnectionFactory

java.lang.Object

org.springframework.amqp.client.SingleAmqpConnectionFactory

All Implemented Interfaces:

AmqpConnectionFactory, Aware, BeanFactoryAware, DisposableBean

public class SingleAmqpConnectionFactory
extends Object
implements AmqpConnectionFactory, BeanFactoryAware, DisposableBean

The AmqpConnectionFactory implementation to hold a single, shared Connection instance. If instance is created without a Client, it will be resolved from the BeanFactory on demand internally from the getConnection() call.

Since:

4.1

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor	Description
SingleAmqpConnectionFactory()	Create an instance based on a Client bean resolved from the BeanFactory.
SingleAmqpConnectionFactory(org.apache.qpid.protonj2.client.Client protonjClient)

Method Summary

Modifier and Type	Method	Description
void	destroy()
org.apache.qpid.protonj2.client.Connection	getConnection()
void	setBeanFactory(BeanFactory beanFactory)
SingleAmqpConnectionFactory	setConnectionOptions(org.apache.qpid.protonj2.client.ConnectionOptions connectionOptions)	Set a ConnectionOptions instance.
SingleAmqpConnectionFactory	setHost(String host)
SingleAmqpConnectionFactory	setPassword(String password)	Set the password for the AMQP connection.
SingleAmqpConnectionFactory	setPort(int port)
SingleAmqpConnectionFactory	setUsername(String username)	Set the username for the AMQP connection.

Methods inherited from class java.lang.Object

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

Constructor Details

SingleAmqpConnectionFactory

public SingleAmqpConnectionFactory()

Create an instance based on a Client bean resolved from the BeanFactory.

SingleAmqpConnectionFactory

public SingleAmqpConnectionFactory(org.apache.qpid.protonj2.client.Client protonjClient)

Method Details

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

setHost

public SingleAmqpConnectionFactory setHost(String host)

setPort

public SingleAmqpConnectionFactory setPort(int port)

setUsername

public SingleAmqpConnectionFactory setUsername(String username)

Set the username for the AMQP connection. The convenient top-level property of the ConnectionOptions. If a ConnectionOptions is provided, the username has to be set over there.

Parameters:

username - the username to use.

Returns:

the factory instance.

setPassword

public SingleAmqpConnectionFactory setPassword(String password)

Set the password for the AMQP connection. The convenient top-level property of the ConnectionOptions. If a ConnectionOptions is provided, the password has to be set over there.

Parameters:

password - the password to use.

Returns:

the factory instance.

setConnectionOptions

public SingleAmqpConnectionFactory setConnectionOptions(org.apache.qpid.protonj2.client.ConnectionOptions connectionOptions)

Set a ConnectionOptions instance. Mutually exclusive with setUsername(String) and setPassword(String).

Parameters:

connectionOptions - to use.

Returns:

the factory instance.

getConnection

public org.apache.qpid.protonj2.client.Connection getConnection()

Specified by:

getConnection in interface AmqpConnectionFactory

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean