You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2021/07/04 04:43:42 UTC
[activemq] branch activemq-5.16.x updated: AMQ-8304: Added a check
with !isStopping() also before attempting to read input stream (#672)
This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch activemq-5.16.x
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/activemq-5.16.x by this push:
new f942276 AMQ-8304: Added a check with !isStopping() also before attempting to read input stream (#672)
f942276 is described below
commit f942276c3043465471d5c049f4ff91998e1d57fa
Author: dvhvsekhar <dv...@yahoo.com>
AuthorDate: Sun Jul 4 10:12:45 2021 +0530
AMQ-8304: Added a check with !isStopping() also before attempting to read input stream (#672)
(cherry picked from commit 8584b46e762b720d6c6fb27fd2124f0e59cef19c)
---
.../src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/activemq-client/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java b/activemq-client/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
index e85cbaf..08a7d80 100644
--- a/activemq-client/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
+++ b/activemq-client/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
@@ -211,7 +211,7 @@ public class TcpTransport extends TransportThreadSupport implements Transport, S
LOG.trace("TCP consumer thread for " + this + " starting");
this.runnerThread=Thread.currentThread();
try {
- while (!isStopped()) {
+ while (!isStopped() && !isStopping()) {
doRun();
}
} catch (IOException e) {