Package io.micronaut.rabbitmq.connect

Class ClusterRabbitConnectionFactoryConfig

java.lang.Object
com.rabbitmq.client.ConnectionFactory
io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig
io.micronaut.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig
All Implemented Interfaces:
Cloneable
@Requires(property="rabbitmq.servers") @EachProperty("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
    Description
    static class 
    ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration
     
    static class 
    ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration
     

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

    RabbitConnectionFactoryConfig.ChannelPoolConfiguration, RabbitConnectionFactoryConfig.RpcConfiguration

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final 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
    Description
    ClusterRabbitConnectionFactoryConfig(String name)
    Default constructor.

  • Method Summary

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

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

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

    Methods inherited from class com.rabbitmq.client.ConnectionFactory

    clone, computeDefaultTlsProtocol, createAddressResolver, createConnection, createFrameHandlerFactory, enableHostnameVerification, enableHostnameVerificationForBlockingIo, enableHostnameVerificationForNio, ensureUnsignedShort, 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, processUriQueryParameter, setAutomaticRecoveryEnabled, setChannelRpcTimeout, setChannelShouldCheckRpcResponseType, setClientProperties, setConnectionRecoveryTriggeringCondition, setConnectionTimeout, setCredentialsProvider, setCredentialsRefreshService, setErrorOnWriteListener, setExceptionHandler, setHandshakeTimeout, setHeartbeatExecutor, setHost, setMaxInboundMessageBodySize, setMetricsCollector, setNetworkRecoveryInterval, setNetworkRecoveryInterval, setNioParams, setObservationCollector, setPassword, setPort, setRecoveredQueueNameSupplier, 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