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 interface
RecoverableConnection
Convenient interface when working against auto-recovery connections.Methods in com.rabbitmq.client that return Connection Modifier and Type Method Description Connection
Channel. getConnection()
Retrieve the connection which carries this channel.Connection
ConnectionFactory. newConnection()
Create a new broker connection.Connection
ConnectionFactory. newConnection(Address[] addrs)
Create a new broker connection, picking the first available address from the list.Connection
ConnectionFactory. newConnection(Address[] addrs, String clientProvidedName)
Create a new broker connection with a client-provided name, picking the first available address from the list.Connection
ConnectionFactory. newConnection(AddressResolver addressResolver)
Create a new broker connection, picking the first available address from the list provided by theAddressResolver
.Connection
ConnectionFactory. newConnection(String connectionName)
Create a new broker connection.Connection
ConnectionFactory. newConnection(ExecutorService executor)
Create a new broker connection.Connection
ConnectionFactory. newConnection(ExecutorService executor, Address[] addrs)
Create a new broker connection, picking the first available address from the list.Connection
ConnectionFactory. 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.Connection
ConnectionFactory. newConnection(ExecutorService executor, AddressResolver addressResolver)
Create a new broker connection, picking the first available address from the list provided by theAddressResolver
.Connection
ConnectionFactory. 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
.Connection
ConnectionFactory. newConnection(ExecutorService executor, String connectionName)
Create a new broker connection.Connection
ConnectionFactory. newConnection(ExecutorService executor, List<Address> addrs)
Create a new broker connection, picking the first available address from the list.Connection
ConnectionFactory. 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.Connection
ConnectionFactory. newConnection(List<Address> addrs)
Create a new broker connection, picking the first available address from the list.Connection
ConnectionFactory. 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 void
MetricsCollector. closeConnection(Connection connection)
void
NoOpMetricsCollector. closeConnection(Connection connection)
void
ExceptionHandler. 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.void
ExceptionHandler. 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.void
ExceptionHandler. 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.void
ExceptionHandler. 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.void
MetricsCollector. newConnection(Connection connection)
void
NoOpMetricsCollector. 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 class
AMQConnection
Concrete 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 void
AbstractMetricsCollector. closeConnection(Connection connection)
protected abstract void
AbstractMetricsCollector. decrementConnectionCount(Connection connection)
Decrements connection count.protected void
MicrometerMetricsCollector. decrementConnectionCount(Connection connection)
protected void
StandardMetricsCollector. decrementConnectionCount(Connection connection)
void
ErrorOnWriteListener. handle(Connection connection, IOException exception)
Called when writing to the socket failedvoid
ForgivingExceptionHandler. handleBlockedListenerException(Connection connection, Throwable exception)
void
StrictExceptionHandler. handleBlockedListenerException(Connection connection, Throwable exception)
protected void
ForgivingExceptionHandler. handleConnectionKiller(Connection connection, Throwable exception, String what)
void
ForgivingExceptionHandler. handleConnectionRecoveryException(Connection conn, Throwable exception)
void
ForgivingExceptionHandler. handleTopologyRecoveryException(Connection conn, Channel ch, TopologyRecoveryException exception)
void
ForgivingExceptionHandler. handleUnexpectedConnectionDriverException(Connection conn, Throwable exception)
protected abstract void
AbstractMetricsCollector. incrementConnectionCount(Connection connection)
Increments connection count.protected void
MicrometerMetricsCollector. incrementConnectionCount(Connection connection)
protected void
StandardMetricsCollector. incrementConnectionCount(Connection connection)
void
AbstractMetricsCollector. 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 class
AutorecoveringConnection
Connection implementation that performs automatic recovery when connection shutdown is not initiated by the application (e.g.class
RecoveryAwareAMQConnection
AMQConnection
modification that usesRecoveryAwareChannelN
Methods in com.rabbitmq.client.impl.recovery that return Connection Modifier and Type Method Description Connection
AutorecoveringChannel. getConnection()
Methods in com.rabbitmq.client.impl.recovery with parameters of type Connection Modifier and Type Method Description void
AutorecoveringChannel. automaticallyRecover(AutorecoveringConnection connection, Connection connDelegate)
-