|
|
@ -233,7 +233,7 @@ public class CachingConnectionFactory extends SingleConnectionFactory { |
|
|
|
else { |
|
|
|
else { |
|
|
|
Session targetSession = createSession(con, mode); |
|
|
|
Session targetSession = createSession(con, mode); |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
logger.debug("Creating cached JMS Session for mode " + mode + ": " + targetSession); |
|
|
|
logger.debug("Registering cached JMS Session for mode " + mode + ": " + targetSession); |
|
|
|
} |
|
|
|
} |
|
|
|
session = getCachedSessionProxy(targetSession, sessionList); |
|
|
|
session = getCachedSessionProxy(targetSession, sessionList); |
|
|
|
} |
|
|
|
} |
|
|
@ -393,7 +393,7 @@ public class CachingConnectionFactory extends SingleConnectionFactory { |
|
|
|
else { |
|
|
|
else { |
|
|
|
producer = this.target.createProducer(dest); |
|
|
|
producer = this.target.createProducer(dest); |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
logger.debug("Creating cached JMS MessageProducer for destination [" + dest + "]: " + producer); |
|
|
|
logger.debug("Registering cached JMS MessageProducer for destination [" + dest + "]: " + producer); |
|
|
|
} |
|
|
|
} |
|
|
|
this.cachedProducers.put(cacheKey, producer); |
|
|
|
this.cachedProducers.put(cacheKey, producer); |
|
|
|
} |
|
|
|
} |
|
|
@ -439,7 +439,7 @@ public class CachingConnectionFactory extends SingleConnectionFactory { |
|
|
|
consumer = this.target.createConsumer(dest, selector); |
|
|
|
consumer = this.target.createConsumer(dest, selector); |
|
|
|
} |
|
|
|
} |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
logger.debug("Creating cached JMS MessageConsumer for destination [" + dest + "]: " + consumer); |
|
|
|
logger.debug("Registering cached JMS MessageConsumer for destination [" + dest + "]: " + consumer); |
|
|
|
} |
|
|
|
} |
|
|
|
this.cachedConsumers.put(cacheKey, consumer); |
|
|
|
this.cachedConsumers.put(cacheKey, consumer); |
|
|
|
} |
|
|
|
} |
|
|
|