private class CachingConnectionFactory.CachedSessionInvocationHandler
extends java.lang.Object
implements java.lang.reflect.InvocationHandler
Modifier and Type | Field and Description |
---|---|
private java.util.Map<CachingConnectionFactory.ConsumerCacheKey,MessageConsumer> |
cachedConsumers |
private java.util.Map<CachingConnectionFactory.DestinationCacheKey,MessageProducer> |
cachedProducers |
private java.util.LinkedList<Session> |
sessionList |
private Session |
target |
private boolean |
transactionOpen |
Constructor and Description |
---|
CachedSessionInvocationHandler(Session target,
java.util.LinkedList<Session> sessionList) |
Modifier and Type | Method and Description |
---|---|
private MessageConsumer |
getCachedConsumer(Destination dest,
java.lang.String selector,
java.lang.Boolean noLocal,
java.lang.String subscription,
boolean durable) |
private MessageProducer |
getCachedProducer(Destination dest) |
java.lang.Object |
invoke(java.lang.Object proxy,
java.lang.reflect.Method method,
java.lang.Object[] args) |
private void |
logicalClose(Session proxy) |
private void |
physicalClose() |
private final Session target
private final java.util.LinkedList<Session> sessionList
private final java.util.Map<CachingConnectionFactory.DestinationCacheKey,MessageProducer> cachedProducers
private final java.util.Map<CachingConnectionFactory.ConsumerCacheKey,MessageConsumer> cachedConsumers
private boolean transactionOpen
public CachedSessionInvocationHandler(Session target, java.util.LinkedList<Session> sessionList)
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.InvocationHandler
java.lang.Throwable
private MessageProducer getCachedProducer(Destination dest) throws JMSException
JMSException
private MessageConsumer getCachedConsumer(Destination dest, java.lang.String selector, java.lang.Boolean noLocal, java.lang.String subscription, boolean durable) throws JMSException
JMSException
private void logicalClose(Session proxy) throws JMSException
JMSException
private void physicalClose() throws JMSException
JMSException