admin/spring-projects-spring-framework
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-framework synced 2026-06-08 17:33:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

CachingConnectionFactory makes its Session caching inactive during reset

Browse Source 
Issue: SPR-16450
This commit is contained in:
Juergen Hoeller
2018-02-02 11:33:10 +01:00
parent 10caaefd0b
commit b6ecfcf9ec
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
spring-jms/src/main/java/org/springframework/jms/connection/CachingConnectionFactory.java
+9 -5
View File
@@ -175,6 +175,7 @@ public class CachingConnectionFactory extends SingleConnectionFactory {
@Override
public void resetConnection() {
this.active = false;
synchronized (this.cachedSessions) {
for (LinkedList<Session> sessionList : this.cachedSessions.values()) {
synchronized (sessionList) {
@@ -190,10 +191,11 @@ public class CachingConnectionFactory extends SingleConnectionFactory {
}
this.cachedSessions.clear();
}
this.active = true;
// Now proceed with actual closing of the shared Connection...
super.resetConnection();
this.active = true;
}
/**
@@ -201,6 +203,10 @@ public class CachingConnectionFactory extends SingleConnectionFactory {
*/
@Override
protected Session getSession(Connection con, Integer mode) throws JMSException {
if (!this.active) {
return null;
}
LinkedList<Session> sessionList;
synchronized (this.cachedSessions) {
sessionList = this.cachedSessions.get(mode);
@@ -264,11 +270,9 @@ public class CachingConnectionFactory extends SingleConnectionFactory {
private final LinkedList<Session> sessionList;
private final Map<DestinationCacheKey, MessageProducer> cachedProducers =
new HashMap<>();
private final Map<DestinationCacheKey, MessageProducer> cachedProducers = new HashMap<>();
private final Map<ConsumerCacheKey, MessageConsumer> cachedConsumers =
new HashMap<>();
private final Map<ConsumerCacheKey, MessageConsumer> cachedConsumers = new HashMap<>();
private boolean transactionOpen = false;