io.micronaut.configuration.rabbitmq.connect

Class ClusterRabbitConnectionFactoryConfig

java.lang.Object

com.rabbitmq.client.ConnectionFactory

io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig

io.micronaut.configuration.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig

All Implemented Interfaces:

Cloneable

@Requires(property="rabbitmq.servers")
 @EachProperty(value="rabbitmq.servers")
public class ClusterRabbitConnectionFactoryConfig
extends RabbitConnectionFactoryConfig

Allows configuration of multiple RabbitMQ connections.

Since:

1.1.0

Author:

James Kleeh

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration
static class	ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration

Nested classes/interfaces inherited from class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig

RabbitConnectionFactoryConfig.ChannelPoolConfiguration, RabbitConnectionFactoryConfig.RpcConfiguration

Field Summary

Fields

Modifier and Type	Field and Description
static String	PREFIX

Fields inherited from class com.rabbitmq.client.ConnectionFactory

DEFAULT_AMQP_OVER_SSL_PORT, DEFAULT_AMQP_PORT, DEFAULT_CHANNEL_MAX, DEFAULT_CHANNEL_RPC_TIMEOUT, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_FRAME_MAX, DEFAULT_HANDSHAKE_TIMEOUT, DEFAULT_HEARTBEAT, DEFAULT_HOST, DEFAULT_NETWORK_RECOVERY_INTERVAL, DEFAULT_PASS, DEFAULT_SHUTDOWN_TIMEOUT, DEFAULT_USER, DEFAULT_VHOST, DEFAULT_WORK_POOL_TIMEOUT, USE_DEFAULT_PORT

Constructor Summary

Constructors

Constructor and Description
ClusterRabbitConnectionFactoryConfig(String name) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	setChannelPool(ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration channelPool) Sets the channel pool configuration.
void	setRpc(ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration rpc) Sets the RPC configuration.

Methods inherited from class io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig

getAddresses, getChannelPool, getConsumerExecutor, getName, getRpc, setAddresses, setChannelPool, setConsumerExecutor, setRpc

Methods inherited from class com.rabbitmq.client.ConnectionFactory

clone, computeDefaultTlsProcotol, createAddressResolver, createConnection, createFrameHandlerFactory, enableHostnameVerification, enableHostnameVerificationForBlockingIo, enableHostnameVerificationForNio, getChannelRpcTimeout, getClientProperties, getConnectionTimeout, getExceptionHandler, getHandshakeTimeout, getHost, getMetricsCollector, getNetworkRecoveryInterval, getNioParams, getPassword, getPort, getRecoveryDelayHandler, getRequestedChannelMax, getRequestedFrameMax, getRequestedHeartbeat, getSaslConfig, getShutdownTimeout, getSocketConfigurator, getSocketFactory, getThreadFactory, getTopologyRecoveryExecutor, getUsername, getVirtualHost, getWorkPoolTimeout, isAutomaticRecoveryEnabled, isChannelShouldCheckRpcResponseType, isSSL, isTopologyRecoveryEnabled, load, load, load, load, load, load, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, newConnection, params, portOrDefault, setAutomaticRecoveryEnabled, setChannelRpcTimeout, setChannelShouldCheckRpcResponseType, setClientProperties, setConnectionRecoveryTriggeringCondition, setConnectionTimeout, setCredentialsProvider, setErrorOnWriteListener, setExceptionHandler, setHandshakeTimeout, setHeartbeatExecutor, setHost, setMetricsCollector, setNetworkRecoveryInterval, setNetworkRecoveryInterval, setNioParams, setPassword, setPort, setRecoveryDelayHandler, setRequestedChannelMax, setRequestedFrameMax, setRequestedHeartbeat, setSaslConfig, setSharedExecutor, setShutdownExecutor, setShutdownTimeout, setSocketConfigurator, setSocketFactory, setSslContextFactory, setThreadFactory, setTopologyRecoveryEnabled, setTopologyRecoveryExecutor, setTopologyRecoveryFilter, setTopologyRecoveryRetryHandler, setTrafficListener, setUri, setUri, setUsername, setVirtualHost, setWorkPoolTimeout, useBlockingIo, useNio, useSslProtocol, useSslProtocol, useSslProtocol, useSslProtocol

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final String PREFIX

See Also:

Constant Field Values

Constructor Detail

ClusterRabbitConnectionFactoryConfig

public ClusterRabbitConnectionFactoryConfig(@Parameter
                                            String name)

Default constructor.

Parameters:

name - The connection name

Method Detail

setRpc

public void setRpc(@Nonnull
                   ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration rpc)

Sets the RPC configuration.

Parameters:

rpc - The RPC configuration

setChannelPool

public void setChannelPool(@Nonnull
                           ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration channelPool)

Sets the channel pool configuration.

Parameters:

channelPool - The channel pool configuration