Package com.rabbitmq.client

Class ConnectionFactory

java.lang.Object

com.rabbitmq.client.ConnectionFactory

All Implemented Interfaces:

Cloneable

public class ConnectionFactory
extends Object
implements Cloneable

Convenience factory class to facilitate opening a Connection to a RabbitMQ node.

Most connection and socket settings are configured using this factory. Some settings that apply to connections can also be configured here and will apply to all connections produced by this factory.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ConnectionFactory.NettyConfiguration	Helper class to configure Netty.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_AMQP_OVER_SSL_PORT	The default ssl port
static final int	DEFAULT_AMQP_PORT	The default non-ssl port
static final int	DEFAULT_CHANNEL_MAX	Default maximum channel number; 2047 because it's 2048 on the server side minus channel 0, which each connection uses for negotiation and error communication
static final int	DEFAULT_CHANNEL_RPC_TIMEOUT	The default continuation timeout for RPC calls in channels: 10 minutes
static final int	DEFAULT_CONNECTION_TIMEOUT	The default TCP connection timeout: 60 seconds
static final int	DEFAULT_FRAME_MAX	Default maximum frame size; zero means no limit
static final int	DEFAULT_HANDSHAKE_TIMEOUT	The default AMQP 0-9-1 connection handshake timeout.
static final int	DEFAULT_HEARTBEAT	Default heart-beat interval; 60 seconds
static final String	DEFAULT_HOST	The default host
static final long	DEFAULT_NETWORK_RECOVERY_INTERVAL	The default network recovery interval: 5000 millis
static final String	DEFAULT_PASS	Default password
static final int	DEFAULT_SHUTDOWN_TIMEOUT	The default shutdown timeout; zero means wait indefinitely
static final String	DEFAULT_USER	Default user name
static final String	DEFAULT_VHOST	Default virtual host
static final int	DEFAULT_WORK_POOL_TIMEOUT	The default timeout for work pool enqueueing: no timeout
static final int	USE_DEFAULT_PORT	'Use the default port' port

Constructor Summary

Constructors

Constructor	Description
ConnectionFactory()

Method Summary

Modifier and Type

Method

Description

ConnectionFactory

clone()

static String

computeDefaultTlsProtocol(String[] supportedProtocols)

protected AddressResolver

createAddressResolver(List<Address> addresses)

protected AMQConnection

createConnection(ConnectionParams params, FrameHandler frameHandler, MetricsCollector metricsCollector)

protected FrameHandlerFactory

createFrameHandlerFactory()

void

enableHostnameVerification()

Enable server hostname verification for TLS connections.

protected void

enableHostnameVerificationForBlockingIo()

protected void