| Package | Description |
|---|---|
| org.springframework.amqp.rabbit.connection |
Provides classes related to connections.
|
| Modifier and Type | Field and Description |
|---|---|
private CachingConnectionFactory.ChannelCachingConnectionProxy |
CachingConnectionFactory.connection |
private CachingConnectionFactory.ChannelCachingConnectionProxy |
CachingConnectionFactory.CachedChannelInvocationHandler.theConnection |
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.BlockingQueue<CachingConnectionFactory.ChannelCachingConnectionProxy> |
CachingConnectionFactory.idleConnections |
private java.util.Map<CachingConnectionFactory.ChannelCachingConnectionProxy,java.util.LinkedList<ChannelProxy>> |
CachingConnectionFactory.openConnectionNonTransactionalChannels |
private java.util.Set<CachingConnectionFactory.ChannelCachingConnectionProxy> |
CachingConnectionFactory.openConnections |
private java.util.Map<CachingConnectionFactory.ChannelCachingConnectionProxy,java.util.LinkedList<ChannelProxy>> |
CachingConnectionFactory.openConnectionTransactionalChannels |
| Modifier and Type | Method and Description |
|---|---|
private com.rabbitmq.client.Channel |
CachingConnectionFactory.createBareChannel(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
boolean transactional) |
private com.rabbitmq.client.Channel |
CachingConnectionFactory.doCreateBareChannel(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
boolean transactional) |
private ChannelProxy |
CachingConnectionFactory.getCachedChannelProxy(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
java.util.LinkedList<ChannelProxy> channelList,
boolean transactional) |
private com.rabbitmq.client.Channel |
CachingConnectionFactory.getChannel(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
boolean transactional) |
| Constructor and Description |
|---|
CachedChannelInvocationHandler(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
com.rabbitmq.client.Channel target,
java.util.LinkedList<ChannelProxy> channelList,
boolean transactional) |