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

[cs...@apache.org]

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

cshannon 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 0a099af  AMQ-8183 - apply maxFrameSize high cpu usage fix to Auto nio transport also
0a099af is described below

commit 0a099af4c4b9841a4517970fec47c34e3f95c91e
Author: Christopher L. Shannon (cshannon) <ch...@gmail.com>
AuthorDate: Thu Mar 11 11:13:35 2021 -0500

    AMQ-8183 - apply maxFrameSize high cpu usage fix to Auto nio transport
    also
    
    (cherry picked from commit 2712464b78f76affd34cc0b097a2248f211ea0c7)
---
 .../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);