Package io.micronaut.rabbitmq.connect

Class SingleRabbitConnectionFactoryConfig

java.lang.Object
com.rabbitmq.client.ConnectionFactory
io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig
io.micronaut.rabbitmq.connect.SingleRabbitConnectionFactoryConfig
All Implemented Interfaces:
Cloneable
@Requires(missingProperty="rabbitmq.servers") @ConfigurationProperties("rabbitmq") @Named("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
    Description
    static class 
    SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration
     
    static class 
    SingleRabbitConnectionFactoryConfig.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
    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
    Description
    SingleRabbitConnectionFactoryConfig()
    Default constructor.

  • Method Summary

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