[activemq] branch master updated: AMQ-8183 - apply maxFrameSize high cpu usage fix to Auto nio transport also

[cshannon]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2712464  AMQ-8183 - apply maxFrameSize high cpu usage fix to Auto nio 
transport also
2712464 is described below

commit 2712464b78f76affd34cc0b097a2248f211ea0c7
Author: Christopher L. Shannon (cshannon) <christopher.l.shan...@gmail.com>
AuthorDate: Thu Mar 11 11:13:35 2021 -0500

    AMQ-8183 - apply maxFrameSize high cpu usage fix to Auto nio transport
    also
---
 .../org/apache/activemq/transport/nio/AutoInitNioSSLTransport.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/transport/nio/AutoInitNioSSLTransport.java
 
b/activemq-broker/src/main/java/org/apache/activemq/transport/nio/AutoInitNioSSLTransport.java
index c0d9df2..98d0d79 100644
--- 
a/activemq-broker/src/main/java/org/apache/activemq/transport/nio/AutoInitNioSSLTransport.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/transport/nio/AutoInitNioSSLTransport.java
@@ -170,6 +170,11 @@ public class AutoInitNioSSLTransport extends 
NIOSSLTransport {
             plain.position(plain.limit());
 
             while (true) {
+                //If the transport was already stopped then break
+                if (this.isStopped()) {
+                    return;
+                }
+
                 if (!plain.hasRemaining()) {
                     int readCount = secureRead(plain);