[activemq] branch main updated: AMQ-8304: Added a check with !isStopping() also before attempting to read input stream (#672)

[jbonofre]

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/main by this push:
     new 8584b46  AMQ-8304: Added a check with !isStopping() also before 
attempting to read input stream (#672)
8584b46 is described below

commit 8584b46e762b720d6c6fb27fd2124f0e59cef19c
Author: dvhvsekhar <dvhv_sek...@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)
---
 .../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) {