|
|
|
@ -305,9 +305,15 @@ public class CachingConnectionFactory extends SingleConnectionFactory { |
|
|
|
if (active) { |
|
|
|
if (active) { |
|
|
|
synchronized (this.sessionList) { |
|
|
|
synchronized (this.sessionList) { |
|
|
|
if (this.sessionList.size() < getSessionCacheSize()) { |
|
|
|
if (this.sessionList.size() < getSessionCacheSize()) { |
|
|
|
logicalClose((Session) proxy); |
|
|
|
try { |
|
|
|
// Remain open in the session list.
|
|
|
|
logicalClose((Session) proxy); |
|
|
|
return null; |
|
|
|
// Remain open in the session list.
|
|
|
|
|
|
|
|
return null; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
catch (JMSException ex) { |
|
|
|
|
|
|
|
logger.trace("Logical close of cached JMS Session failed - discarding it", ex); |
|
|
|
|
|
|
|
// Proceed to physical close from here...
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|