This is an automated email from the ASF dual-hosted git repository. orudyy pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
commit 1d327d9b1ad316c0d78d6fe78a96a36108ef274c Author: Alex Rudyy <[email protected]> AuthorDate: Fri Aug 23 13:10:54 2019 +0100 QPID-8349: [Tests][AMQP 1.0] Report decoding errors --- .../apache/qpid/tests/protocol/v1_0/FrameDecoder.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) 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 class FrameDecoder implements InputDecoder public void handleError(final Error parsingError) { LOGGER.error("Unexpected error {}", parsingError); + _responseQueue.add(new FrameDecodeError(parsingError)); } @Override @@ -289,4 +290,20 @@ public class FrameDecoder implements InputDecoder } } + + private static class FrameDecodeError implements Response<Error> + { + private final Error _error; + + FrameDecodeError(final Error error) + { + _error = error; + } + + @Override + public Error getBody() + { + return _error; + } + } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
