Uses of Class
com.rabbitmq.client.impl.AMQConnection
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
Implementations of interfaces specified in the client API, and their supporting classes.
NIO network connector.
Implementation of connection and topology recovery.
-
Uses of AMQConnection in com.rabbitmq.client
Modifier and TypeMethodDescriptionprotected AMQConnection
ConnectionFactory.createConnection
(ConnectionParams params, FrameHandler frameHandler, MetricsCollector metricsCollector) -
Uses of AMQConnection in com.rabbitmq.client.impl
Modifier and TypeMethodDescriptionChannelManager.createChannel
(AMQConnection connection) ChannelManager.createChannel
(AMQConnection connection, int channelNumber) void
FrameHandler.initialize
(AMQConnection connection) void
SocketFrameHandler.initialize
(AMQConnection connection) protected ChannelN
ChannelManager.instantiateChannel
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) ModifierConstructorDescriptionAMQChannel
(AMQConnection connection, int channelNumber) Construct a channel on the given connection, with the given channel number.ChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) Construct a new channel on the given connection with the given channel number.ChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService, MetricsCollector metricsCollector, ObservationCollector observationCollector) Construct a new channel on the given connection with the given channel number. -
Uses of AMQConnection in com.rabbitmq.client.impl.nio
Modifier and TypeMethodDescriptionvoid
SocketChannelFrameHandler.initialize
(AMQConnection connection) void
SocketChannelFrameHandlerState.setConnection
(AMQConnection connection) -
Uses of AMQConnection in com.rabbitmq.client.impl.recovery
Modifier and TypeClassDescriptionclass
AMQConnection
modification that usesRecoveryAwareChannelN
Modifier and TypeMethodDescriptionAutorecoveringConnection.getDelegate()
Not supposed to be used outside of automated tests.Modifier and TypeMethodDescriptionprotected ChannelN
RecoveryAwareChannelManager.instantiateChannel
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) ModifierConstructorDescriptionRecoveryAwareChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService) Construct a new channel on the given connection with the given channel number.RecoveryAwareChannelN
(AMQConnection connection, int channelNumber, ConsumerWorkService workService, MetricsCollector metricsCollector, ObservationCollector observationCollector) Construct a new channel on the given connection with the given channel number.