Class RecoveryAwareAMQConnectionFactory
- java.lang.Object
-
- com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory
-
public class RecoveryAwareAMQConnectionFactory extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private AddressResolver
addressResolver
private FrameHandlerFactory
factory
private MetricsCollector
metricsCollector
private ObservationCollector
observationCollector
private ConnectionParams
params
-
Constructor Summary
Constructors Constructor Description RecoveryAwareAMQConnectionFactory(ConnectionParams params, FrameHandlerFactory factory, AddressResolver addressResolver)
RecoveryAwareAMQConnectionFactory(ConnectionParams params, FrameHandlerFactory factory, AddressResolver addressResolver, MetricsCollector metricsCollector, ObservationCollector observationCollector)
RecoveryAwareAMQConnectionFactory(ConnectionParams params, FrameHandlerFactory factory, java.util.List<Address> addrs)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private java.lang.String
connectionName()
protected RecoveryAwareAMQConnection
createConnection(ConnectionParams params, FrameHandler handler, MetricsCollector metricsCollector)
RecoveryAwareAMQConnection
newConnection()
-
-
-
Field Detail
-
params
private final ConnectionParams params
-
factory
private final FrameHandlerFactory factory
-
addressResolver
private final AddressResolver addressResolver
-
metricsCollector
private final MetricsCollector metricsCollector
-
observationCollector
private final ObservationCollector observationCollector
-
-
Constructor Detail
-
RecoveryAwareAMQConnectionFactory
public RecoveryAwareAMQConnectionFactory(ConnectionParams params, FrameHandlerFactory factory, java.util.List<Address> addrs)
-
RecoveryAwareAMQConnectionFactory
public RecoveryAwareAMQConnectionFactory(ConnectionParams params, FrameHandlerFactory factory, AddressResolver addressResolver)
-
RecoveryAwareAMQConnectionFactory
public RecoveryAwareAMQConnectionFactory(ConnectionParams params, FrameHandlerFactory factory, AddressResolver addressResolver, MetricsCollector metricsCollector, ObservationCollector observationCollector)
-
-
Method Detail
-
newConnection
public RecoveryAwareAMQConnection newConnection() throws java.io.IOException, java.util.concurrent.TimeoutException
- Returns:
- an interface to the connection
- Throws:
java.io.IOException
- if it encounters a problemjava.util.concurrent.TimeoutException
-
createConnection
protected RecoveryAwareAMQConnection createConnection(ConnectionParams params, FrameHandler handler, MetricsCollector metricsCollector)
-
connectionName
private java.lang.String connectionName()
-
-