Uses of Interface
com.rabbitmq.client.Connection
-
Packages that use Connection Package Description com.rabbitmq.client The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors.com.rabbitmq.client.impl Implementations of interfaces specified in the client API, and their supporting classes.com.rabbitmq.client.impl.recovery Implementation of connection and topology recovery. -
-
Uses of Connection in com.rabbitmq.client
Subinterfaces of Connection in com.rabbitmq.client Modifier and Type Interface Description interfaceRecoverableConnectionConvenient interface when working against auto-recovery connections.Methods in com.rabbitmq.client that return Connection Modifier and Type Method Description ConnectionChannel. getConnection()Retrieve the connection which carries this channel.ConnectionConnectionFactory. newConnection()Create a new broker connection.ConnectionConnectionFactory. newConnection(Address[] addrs)Create a new broker connection, picking the first available address from the list.ConnectionConnectionFactory. newConnection(Address[] addrs, String clientProvidedName)Create a new broker connection with a client-provided name, picking the first available address from the list.ConnectionConnectionFactory. newConnection(AddressResolver addressResolver)Create a new broker connection, picking the first available address from the list provided by theAddressResolver.ConnectionConnectionFactory. newConnection(String connectionName)Create a new broker connection.ConnectionConnectionFactory. newConnection(ExecutorService executor)Create a new broker connection.ConnectionConnectionFactory. newConnection(ExecutorService executor, Address[] addrs)Create a new broker connection, picking the first available address from the list.ConnectionConnectionFactory. newConnection(ExecutorService executor, Address[] addrs, String clientProvidedName)Create a new broker connection with a client-provided name, picking the first available address from the list.ConnectionConnectionFactory. newConnection(ExecutorService executor, AddressResolver addressResolver)Create a new broker connection, picking the first available address from the list provided by theAddressResolver.ConnectionConnectionFactory. newConnection(ExecutorService executor, AddressResolver addressResolver, String clientProvidedName)Create a new broker connection with a client-provided name, picking the first available address from the list provided by theAddressResolver.ConnectionConnectionFactory. newConnection(ExecutorService executor, String connectionName)Create a new broker connection.ConnectionConnectionFactory. newConnection(ExecutorService executor, List<Address> addrs)Create a new broker connection, picking the first available address from the list.ConnectionConnectionFactory. newConnection(ExecutorService executor, List<Address> addrs, String clientProvidedName)Create a new broker connection with a client-provided name, picking the first available address from the list.ConnectionConnectionFactory. newConnection(List<Address> addrs)Create a new broker connection, picking the first available address from the list.ConnectionConnectionFactory. newConnection(List<Address> addrs, String clientProvidedName)Create a new broker connection with a client-provided name, picking the first available address from the list.Methods in com.rabbitmq.client with parameters of type Connection Modifier and Type Method Description voidMetricsCollector. closeConnection(Connection connection)voidNoOpMetricsCollector. closeConnection(Connection connection)voidExceptionHandler. handleBlockedListenerException(Connection connection, Throwable exception)Perform any required exception processing for the situation when the driver thread for the connection has called a BlockedListener's method, and that method has thrown an exception.voidExceptionHandler. handleConnectionRecoveryException(Connection conn, Throwable exception)Perform any required exception processing for the situation when the driver thread for the connection has an exception during connection recovery that it can't otherwise deal with.voidExceptionHandler. handleTopologyRecoveryException(Connection conn, Channel ch, TopologyRecoveryException exception)Perform any required exception processing for the situation when the driver thread for the connection has an exception during topology (exchanges, queues, bindings, consumers) recovery that it can't otherwise deal with.voidExceptionHandler. handleUnexpectedConnectionDriverException(Connection conn, Throwable exception)Perform any required exception processing for the situation when the driver thread for the connection has an exception signalled to it that it can't otherwise deal with.voidMetricsCollector. newConnection(Connection connection)voidNoOpMetricsCollector. newConnection(Connection connection) -
Uses of Connection in com.rabbitmq.client.impl
Classes in com.rabbitmq.client.impl that implement Connection Modifier and Type Class Description classAMQConnectionConcrete class representing and managing an AMQP connection to a broker.Methods in com.rabbitmq.client.impl with parameters of type Connection Modifier and Type Method Description voidAbstractMetricsCollector. closeConnection(Connection connection)protected abstract voidAbstractMetricsCollector. decrementConnectionCount(Connection connection)Decrements connection count.protected voidMicrometerMetricsCollector. decrementConnectionCount(Connection connection)protected voidStandardMetricsCollector. decrementConnectionCount(Connection connection)voidErrorOnWriteListener. handle(Connection connection, IOException exception)Called when writing to the socket failedvoidForgivingExceptionHandler. handleBlockedListenerException(Connection connection, Throwable exception)voidStrictExceptionHandler. handleBlockedListenerException(Connection connection, Throwable exception)protected voidForgivingExceptionHandler. handleConnectionKiller(Connection connection, Throwable exception, String what)voidForgivingExceptionHandler. handleConnectionRecoveryException(Connection conn, Throwable exception)voidForgivingExceptionHandler. handleTopologyRecoveryException(Connection conn, Channel ch, TopologyRecoveryException exception)voidForgivingExceptionHandler. handleUnexpectedConnectionDriverException(Connection conn, Throwable exception)protected abstract voidAbstractMetricsCollector. incrementConnectionCount(Connection connection)Increments connection count.protected voidMicrometerMetricsCollector. incrementConnectionCount(Connection connection)protected voidStandardMetricsCollector. incrementConnectionCount(Connection connection)voidAbstractMetricsCollector. newConnection(Connection connection) -
Uses of Connection in com.rabbitmq.client.impl.recovery
Classes in com.rabbitmq.client.impl.recovery that implement Connection Modifier and Type Class Description classAutorecoveringConnectionConnection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g.classRecoveryAwareAMQConnectionAMQConnectionmodification that usesRecoveryAwareChannelNMethods in com.rabbitmq.client.impl.recovery that return Connection Modifier and Type Method Description ConnectionAutorecoveringChannel. getConnection()Methods in com.rabbitmq.client.impl.recovery with parameters of type Connection Modifier and Type Method Description voidAutorecoveringChannel. automaticallyRecover(AutorecoveringConnection connection, Connection connDelegate)
-