private class CachingConnectionFactory.CachedChannelInvocationHandler
extends java.lang.Object
implements java.lang.reflect.InvocationHandler
| Modifier and Type | Field and Description |
|---|---|
private java.util.LinkedList<ChannelProxy> |
channelList |
private com.rabbitmq.client.Channel |
target |
private java.lang.Object |
targetMonitor |
private CachingConnectionFactory.ChannelCachingConnectionProxy |
theConnection |
private boolean |
transactional |
| Constructor and Description |
|---|
CachedChannelInvocationHandler(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
com.rabbitmq.client.Channel target,
java.util.LinkedList<ChannelProxy> channelList,
boolean transactional) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Object |
invoke(java.lang.Object proxy,
java.lang.reflect.Method method,
java.lang.Object[] args) |
private void |
logicalClose(ChannelProxy proxy)
GUARDED by channelList
|
private void |
physicalClose() |
private final CachingConnectionFactory.ChannelCachingConnectionProxy theConnection
private volatile com.rabbitmq.client.Channel target
private final java.util.LinkedList<ChannelProxy> channelList
private final java.lang.Object targetMonitor
private final boolean transactional
public CachedChannelInvocationHandler(CachingConnectionFactory.ChannelCachingConnectionProxy connection, com.rabbitmq.client.Channel target, java.util.LinkedList<ChannelProxy> channelList, boolean transactional)
public java.lang.Object invoke(java.lang.Object proxy,
java.lang.reflect.Method method,
java.lang.Object[] args)
throws java.lang.Throwable
invoke in interface java.lang.reflect.InvocationHandlerjava.lang.Throwableprivate void logicalClose(ChannelProxy proxy) throws java.lang.Exception
proxy - the channel to closejava.lang.Exceptionprivate void physicalClose()
throws java.lang.Exception
java.lang.Exception