org.springframework.amqp.rabbit.connection

Class CachingConnectionFactory.CachedChannelInvocationHandler

java.lang.Object

org.springframework.amqp.rabbit.connection.CachingConnectionFactory.CachedChannelInvocationHandler

All Implemented Interfaces:

java.lang.reflect.InvocationHandler

Enclosing class:

CachingConnectionFactory

private class CachingConnectionFactory.CachedChannelInvocationHandler
extends java.lang.Object
implements java.lang.reflect.InvocationHandler

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
CachedChannelInvocationHandler(CachingConnectionFactory.ChannelCachingConnectionProxy connection, com.rabbitmq.client.Channel target, java.util.LinkedList<ChannelProxy> channelList, boolean transactional)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

theConnection

private final CachingConnectionFactory.ChannelCachingConnectionProxy theConnection

target

private volatile com.rabbitmq.client.Channel target

channelList

private final java.util.LinkedList<ChannelProxy> channelList

targetMonitor

private final java.lang.Object targetMonitor

transactional

private final boolean transactional

Constructor Detail

CachedChannelInvocationHandler

public CachedChannelInvocationHandler(CachingConnectionFactory.ChannelCachingConnectionProxy connection,
                                      com.rabbitmq.client.Channel target,
                                      java.util.LinkedList<ChannelProxy> channelList,
                                      boolean transactional)

Method Detail

invoke

public java.lang.Object invoke(java.lang.Object proxy,
                               java.lang.reflect.Method method,
                               java.lang.Object[] args)
                        throws java.lang.Throwable

Specified by:

invoke in interface java.lang.reflect.InvocationHandler

Throws:

java.lang.Throwable

logicalClose

private void logicalClose(ChannelProxy proxy)
                   throws java.lang.Exception

GUARDED by channelList

Parameters:

proxy - the channel to close

Throws:

java.lang.Exception

physicalClose

private void physicalClose()
                    throws java.lang.Exception

Throws:

java.lang.Exception