commit 1d327d9b1ad316c0d78d6fe78a96a36108ef274c
author Alex Rudyy <orudyy@apache.org> Fri Aug 23 13:10:54 2019 +0100
committer Alex Rudyy <orudyy@apache.org> Fri Aug 23 13:10:54 2019 +0100
tree 983554b3b0135ac4e4324699c44462587bcc3943
parent af83b6db0463d095f626592e15a9e4f5297281f7

QPID-8349: [Tests][AMQP 1.0] Report decoding errors

systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameDecoder.java

diff --git a/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameDecoder.java b/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameDecoder.java
index 39b16fa..0e86c01 100644
--- a/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameDecoder.java
+++ b/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameDecoder.java
@@ -210,6 +210,7 @@
         public void handleError(final Error parsingError)
         {
             LOGGER.error("Unexpected error {}", parsingError);
+            _responseQueue.add(new FrameDecodeError(parsingError));
         }
 
         @Override
@@ -289,4 +290,20 @@
 
         }
     }
+
+    private static class FrameDecodeError implements Response<Error>
+    {
+        private final Error _error;
+
+        FrameDecodeError(final Error error)
+        {
+            _error = error;
+        }
+
+        @Override
+        public Error getBody()
+        {
+            return _error;
+        }
+    }
 }