ATS-23

appNG · Apr 3, 2020 · 31d15d5 · 31d15d5
1 parent 65381ba
commit 31d15d5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/org/appng/tomcat/session/mongo/MongoStore.java b/src/main/java/org/appng/tomcat/session/mongo/MongoStore.java
@@ -332,7 +332,7 @@ public StandardSession load(String id) throws ClassNotFoundException, IOExceptio
 						session.readObjectData(ois);
 						session.setManager(this.manager);
 
-						if (!(sticky || TOMCAT_SESSION_THREAD.equals(threadName))) {
+						if (!(sticky || threadName.startsWith(TOMCAT_SESSION_THREAD))) {
 							BasicDBObject setHost = new BasicDBObject("$set", new BasicDBObject(HOST_PROPERTY,
 									String.format("%s@%s", Thread.currentThread().getName(), hostName)));
 							this.collection.update(sessionQuery, setHost);
@@ -362,7 +362,7 @@ private DBObject getMongoSession(String id) {
 		if (sticky) {
 			String owningThread = null;
 			String threadName = Thread.currentThread().getName();
-			if (!TOMCAT_SESSION_THREAD.equals(threadName)) {
+			if (!threadName.startsWith(TOMCAT_SESSION_THREAD)) {
 				while (waited < maxWaitTime && (owningThread = sessionsInUse.get(id)) != null
 						&& !owningThread.equals(threadName)) {
 					info("Session %s is still used by thread %s, waiting %sms.", id, owningThread, waitTime);