Handle session thread (#3132)

akka · Feb 29, 2024 · 0405936 · 0405936
1 parent 67523f4
commit 0405936
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/jms/src/main/scala/akka/stream/alpakka/jms/impl/Sessions.scala b/jms/src/main/scala/akka/stream/alpakka/jms/impl/Sessions.scala
@@ -97,7 +97,8 @@ private[jms] final class JmsAckSession(override val connection: jms.Connection,
 
   private def stopMessageListenerAndCloseSession(): Unit = {
     try {
-      drainAcks()
+      if (session.getAcknowledgeMode() == jms.Session.CLIENT_ACKNOWLEDGE)
+        drainAcks()
     } finally {
       ackQueue.put(Left(SessionClosed))
       session.close()