Class AmqpConnectionFactoryBean

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<com.rabbitmq.client.amqp.Connection>

org.springframework.amqp.rabbitmq.client.AmqpConnectionFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<com.rabbitmq.client.amqp.Connection>, InitializingBean

public class AmqpConnectionFactoryBean
extends AbstractFactoryBean<com.rabbitmq.client.amqp.Connection>

The AbstractFactoryBean for RabbitMQ AMQP 1.0 Connection. A Spring-friendly wrapper around Environment.connectionBuilder();

Since:

4.0

Author:

Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	AmqpConnectionFactoryBean.Affinity
static final class	AmqpConnectionFactoryBean.OAuth2
static final class	AmqpConnectionFactoryBean.Recovery
static enum	AmqpConnectionFactoryBean.SaslMechanism
static final class	AmqpConnectionFactoryBean.Tls

Field Summary

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

logger

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
AmqpConnectionFactoryBean(com.rabbitmq.client.amqp.Environment amqpEnvironment)

Method Summary

Modifier and Type	Method	Description
protected com.rabbitmq.client.amqp.Connection	createInstance()
protected void	destroyInstance(@Nullable com.rabbitmq.client.amqp.Connection instance)
@Nullable Class<?>	getObjectType()
AmqpConnectionFactoryBean	setAddressSelector(com.rabbitmq.client.amqp.AddressSelector addressSelector)
AmqpConnectionFactoryBean	setAffinity(Consumer<AmqpConnectionFactoryBean.Affinity> affinityCustomizer)
AmqpConnectionFactoryBean	setCredentialsProvider(com.rabbitmq.client.amqp.CredentialsProvider credentialsProvider)
AmqpConnectionFactoryBean	setHost(String host)
AmqpConnectionFactoryBean	setIdleTimeout(Duration idleTimeout)
AmqpConnectionFactoryBean	setListeners(com.rabbitmq.client.amqp.Resource.StateListener... listeners)
AmqpConnectionFactoryBean	setOAuth2(Consumer<AmqpConnectionFactoryBean.OAuth2> oauth2Customizer)
AmqpConnectionFactoryBean	setPassword(String password)
AmqpConnectionFactoryBean	setPort(int port)
AmqpConnectionFactoryBean	setRecovery(Consumer<AmqpConnectionFactoryBean.Recovery> recoveryCustomizer)
AmqpConnectionFactoryBean	setSaslMechanism(AmqpConnectionFactoryBean.SaslMechanism saslMechanism)
AmqpConnectionFactoryBean	setTls(Consumer<AmqpConnectionFactoryBean.Tls> tlsCustomizer)
AmqpConnectionFactoryBean	setUri(String uri)
AmqpConnectionFactoryBean	setUris(String... uris)
AmqpConnectionFactoryBean	setUsername(String username)
AmqpConnectionFactoryBean	setVirtualHost(String virtualHost)

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

Constructor Details

AmqpConnectionFactoryBean

public AmqpConnectionFactoryBean(com.rabbitmq.client.amqp.Environment amqpEnvironment)

Method Details

setHost

public AmqpConnectionFactoryBean setHost(String host)

setPort

public AmqpConnectionFactoryBean setPort(int port)

setUsername

public AmqpConnectionFactoryBean setUsername(String username)

setPassword

public AmqpConnectionFactoryBean setPassword(String password)

setVirtualHost

public AmqpConnectionFactoryBean setVirtualHost(String virtualHost)

setUri

public AmqpConnectionFactoryBean setUri(String uri)

setUris

public AmqpConnectionFactoryBean setUris(String... uris)

setIdleTimeout

public AmqpConnectionFactoryBean setIdleTimeout(Duration idleTimeout)

setAddressSelector

public AmqpConnectionFactoryBean setAddressSelector(com.rabbitmq.client.amqp.AddressSelector addressSelector)

setCredentialsProvider

public AmqpConnectionFactoryBean setCredentialsProvider(com.rabbitmq.client.amqp.CredentialsProvider credentialsProvider)

setSaslMechanism

public AmqpConnectionFactoryBean setSaslMechanism(AmqpConnectionFactoryBean.SaslMechanism saslMechanism)

setTls

public AmqpConnectionFactoryBean setTls(Consumer<AmqpConnectionFactoryBean.Tls> tlsCustomizer)

setAffinity

public AmqpConnectionFactoryBean setAffinity(Consumer<AmqpConnectionFactoryBean.Affinity> affinityCustomizer)

setOAuth2

public AmqpConnectionFactoryBean setOAuth2(Consumer<AmqpConnectionFactoryBean.OAuth2> oauth2Customizer)

setRecovery

public AmqpConnectionFactoryBean setRecovery(Consumer<AmqpConnectionFactoryBean.Recovery> recoveryCustomizer)

setListeners

public AmqpConnectionFactoryBean setListeners(com.rabbitmq.client.amqp.Resource.StateListener... listeners)

getObjectType

public @Nullable Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<com.rabbitmq.client.amqp.Connection>

Specified by:

getObjectType in class AbstractFactoryBean<com.rabbitmq.client.amqp.Connection>

createInstance

protected com.rabbitmq.client.amqp.Connection createInstance()

Specified by:

createInstance in class AbstractFactoryBean<com.rabbitmq.client.amqp.Connection>

destroyInstance

protected void destroyInstance(@Nullable com.rabbitmq.client.amqp.Connection instance)

Overrides:

destroyInstance in class AbstractFactoryBean<com.rabbitmq.client.amqp.Connection>