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:42:55 UTC
[activemq] branch main 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 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 <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)
---
.../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) {