AMQ-9658 - Improve auto+nio+ssl transport initialization for amqp

This makes small fix to ensure that the full initialization
buffer will always be entirely read and processed when using
the auto+nio+ssl transport with amqp. Previously the code assumed
only 8 bytes would ever exist (which should be the case under normal
circumstances) but now it will handle any extra bytes if a client sent
more.

Author: cshannon

activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpNioSslTransport.java

@@ -54,6 +54,22 @@ public AmqpNioSslTransport(WireFormat wireFormat, Socket socket,
     @Override
     protected void initializeStreams() throws IOException {
         super.initializeStreams();
+        if (initBuffer != null) {
+            initBuffer.buffer.flip();
+            // If we are processing the initial buffer from the auto transport,
+            // then process first. This generally should only have 8 bytes from
+            // the initial read
+            if (initBuffer.buffer.hasRemaining()) {
+                receiveCounter.addAndGet(initBuffer.readSize);
+                try {
+                    // one call is all that is needed to consume all data
+                    processCommand(initBuffer.buffer);
+                } catch (Exception e) {
+                    throw new IOException(e);
+                }
+                initBuffer.buffer.clear();
+            }
+        }
         if (inputBuffer.position() != 0 && inputBuffer.hasRemaining()) {
             serviceRead();
         }
@@ -76,23 +92,4 @@ protected void doInit() throws Exception {
         super.doInit();
     }
 
-    @Override
-    protected int secureRead(ByteBuffer plain) throws Exception {
-        if (initBuffer != null) {
-            initBuffer.buffer.flip();
-            if (initBuffer.buffer.hasRemaining()) {
-                plain.flip();
-                for (int i =0; i < 8; i++) {
-                    plain.put(initBuffer.buffer.get());
-                }
-                plain.flip();
-                processCommand(plain);
-                initBuffer.buffer.clear();
-                return 8;
-            }
-        }
-        return super.secureRead(plain);
-    }
-
-
-}
+}