Class SingleAmqpConnectionFactory

java.lang.Object

org.springframework.amqp.rabbitmq.client.SingleAmqpConnectionFactory

All Implemented Interfaces:

AmqpConnectionFactory, DisposableBean

public class SingleAmqpConnectionFactory
extends Object
implements AmqpConnectionFactory, DisposableBean

The AmqpConnectionFactory implementation to hold a single, shared Connection instance.

Since:

4.0

Author:

Artem Bilan

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

SingleAmqpConnectionFactory

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

Method Details

setHost

public SingleAmqpConnectionFactory setHost(String host)

setPort

public SingleAmqpConnectionFactory setPort(int port)

setUsername

public SingleAmqpConnectionFactory setUsername(String username)

setPassword

public SingleAmqpConnectionFactory setPassword(String password)

setVirtualHost

public SingleAmqpConnectionFactory setVirtualHost(String virtualHost)

setUri

public SingleAmqpConnectionFactory setUri(String uri)

setUris

public SingleAmqpConnectionFactory setUris(String... uris)

setIdleTimeout

public SingleAmqpConnectionFactory setIdleTimeout(Duration idleTimeout)

setAddressSelector

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

setCredentialsProvider

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

setSaslMechanism

public SingleAmqpConnectionFactory setSaslMechanism(SingleAmqpConnectionFactory.SaslMechanism saslMechanism)

setTls

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

setAffinity

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

setOAuth2

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

setRecovery

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

setListeners

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

getConnection

public com.rabbitmq.client.amqp.Connection getConnection()

Specified by:

getConnection in interface AmqpConnectionFactory

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean