io.micronaut.configuration.rabbitmq.connect

Class SingleRabbitConnectionFactoryConfig

java.lang.Object

com.rabbitmq.client.ConnectionFactory

io.micronaut.configuration.rabbitmq.connect.RabbitConnectionFactoryConfig

io.micronaut.configuration.rabbitmq.connect.SingleRabbitConnectionFactoryConfig

All Implemented Interfaces:

Cloneable

@Requires(missingProperty="rabbitmq.servers")
 @ConfigurationProperties(value="rabbitmq")
 @Named(value="default")
public class SingleRabbitConnectionFactoryConfig
extends RabbitConnectionFactoryConfig

The default RabbitMQ configuration class. Allows RabbitMQ client to leverage Micronaut properties configuration

Since:

1.0

Author:

benrhine

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration
static class	SingleRabbitConnectionFactoryConfig.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	DEFAULT_NAME

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
SingleRabbitConnectionFactoryConfig() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	setChannelPool(SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration channelPool) Sets the channel pool configuration.
void	setRpc(SingleRabbitConnectionFactoryConfig.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

DEFAULT_NAME

public static final String DEFAULT_NAME

See Also:

Constant Field Values

Constructor Detail

SingleRabbitConnectionFactoryConfig

public SingleRabbitConnectionFactoryConfig()

Default constructor.

Method Detail

setRpc

public void setRpc(@Nonnull
                   SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration rpc)

Sets the RPC configuration.

Parameters:

rpc - The RPC configuration

setChannelPool

public void setChannelPool(@Nonnull
                           SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration channelPool)

Sets the channel pool configuration.

Parameters:

channelPool - The channel pool configuration