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)
@Nullable 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(@Nullable Destination dest) throws JMSException
JMSException
private MessageConsumer getCachedConsumer(Destination dest, @Nullable java.lang.String selector, @Nullable java.lang.Boolean noLocal, @Nullable java.lang.String subscription, boolean durable) throws JMSException
JMSException
private void logicalClose(Session proxy) throws JMSException
JMSException
private void physicalClose() throws JMSException
JMSException