| Package | Description |
|---|---|
| org.springframework.amqp.rabbit.connection |
Provides classes related to connections.
|
| Modifier and Type | Field and Description |
|---|---|
private java.util.LinkedList<ChannelProxy> |
CachingConnectionFactory.cachedChannelsNonTransactional |
private java.util.LinkedList<ChannelProxy> |
CachingConnectionFactory.cachedChannelsTransactional |
private java.util.LinkedList<ChannelProxy> |
CachingConnectionFactory.CachedChannelInvocationHandler.channelList |
private java.util.Map<CachingConnectionFactory.ChannelCachingConnectionProxy,java.util.LinkedList<ChannelProxy>> |
CachingConnectionFactory.openConnectionNonTransactionalChannels |
private java.util.Map<CachingConnectionFactory.ChannelCachingConnectionProxy,java.util.LinkedList<ChannelProxy>> |
CachingConnectionFactory.openConnectionTransactionalChannels |
| Modifier and Type | Method and Description |
|---|---|
private ChannelProxy |
CachingConnectionFactory.getCachedChannelProxy(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
java.util.LinkedList<ChannelProxy> channelList,
boolean transactional) |
| Modifier and Type | Method and Description |
|---|---|
private void |
CachingConnectionFactory.CachedChannelInvocationHandler.logicalClose(ChannelProxy proxy)
GUARDED by channelList
|
| Modifier and Type | Method and Description |
|---|---|
private ChannelProxy |
CachingConnectionFactory.getCachedChannelProxy(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
java.util.LinkedList<ChannelProxy> channelList,
boolean transactional) |
| Constructor and Description |
|---|
CachedChannelInvocationHandler(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
com.rabbitmq.client.Channel target,
java.util.LinkedList<ChannelProxy> channelList,
boolean transactional) |