| Package | Description |
|---|---|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
ChannelN |
ChannelManager.createChannel(AMQConnection connection) |
ChannelN |
ChannelManager.createChannel(AMQConnection connection,
int channelNumber) |
ChannelN |
ChannelManager.getChannel(int channelNumber)
Looks up a channel on this connection.
|
protected ChannelN |
ChannelManager.instantiateChannel(AMQConnection connection,
int channelNumber,
ConsumerWorkService workService) |
| Modifier and Type | Method and Description |
|---|---|
void |
AMQConnection.disconnectChannel(ChannelN channel)
Protected API - respond, in the driver thread, to a ShutdownSignal.
|
void |
ChannelManager.releaseChannelNumber(ChannelN channel)
Remove the channel from the channel map and free the number for re-use.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RecoveryAwareChannelN
ChannelN modification that keeps track of delivery
tags and avoids sending |
| Modifier and Type | Method and Description |
|---|---|
protected ChannelN |
RecoveryAwareChannelManager.instantiateChannel(AMQConnection connection,
int channelNumber,
ConsumerWorkService workService) |
Copyright © 2021 VMware, Inc. or its affiliates.. All rights reserved.