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 6e4d71679c92663d1d61fc93d9b17f4c20793bcb Author: Alex Rudyy <[email protected]> AuthorDate: Mon Aug 19 14:16:09 2019 +0100 QPID-8349: [Tests][AMQP 1.0] Log sent and received performatives in test interaction --- .../java/org/apache/qpid/tests/protocol/v1_0/FrameDecoder.java | 7 ++++++- .../java/org/apache/qpid/tests/protocol/v1_0/FrameEncoder.java | 8 +++++++- 2 files changed, 13 insertions(+), 2 deletions(-) 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 a8ab32e..39b16fa 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 @@ -60,6 +60,7 @@ import org.apache.qpid.tests.protocol.Response; public class FrameDecoder implements InputDecoder { + private static final Logger FRAME_LOGGER = LoggerFactory.getLogger("amqp.frame"); private static final Logger LOGGER = LoggerFactory.getLogger(FrameDecoder.class); private static final AMQPDescribedTypeRegistry TYPE_REGISTRY = AMQPDescribedTypeRegistry.newInstance() .registerTransportLayer() @@ -104,7 +105,10 @@ public class FrameDecoder implements InputDecoder { byte[] header = new byte[8]; inputBuffer.get(header); - _connectionHandler._responseQueue.add(new HeaderResponse(header)); + + HeaderResponse headerResponse = new HeaderResponse(header); + FRAME_LOGGER.debug("RECV:" + headerResponse); + _connectionHandler._responseQueue.add(headerResponse); _state = ParsingState.PERFORMATIVES; } break; @@ -250,6 +254,7 @@ public class FrameDecoder implements InputDecoder throw new UnsupportedOperationException("Unexpected frame type : " + val.getClass()); } + FRAME_LOGGER.debug("RECV:" + response.getBody()); _responseQueue.add(response); } } diff --git a/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameEncoder.java b/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameEncoder.java index 748407f..1a99d3d 100644 --- a/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameEncoder.java +++ b/systests/protocol-tests-amqp-1-0/src/main/java/org/apache/qpid/tests/protocol/v1_0/FrameEncoder.java @@ -24,6 +24,9 @@ import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.List; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import org.apache.qpid.server.bytebuffer.QpidByteBuffer; import org.apache.qpid.server.protocol.v1_0.codec.FrameWriter; import org.apache.qpid.server.protocol.v1_0.framing.AMQFrame; @@ -35,6 +38,7 @@ import org.apache.qpid.tests.protocol.v1_0.extensions.type.TestFilterWriter; public class FrameEncoder implements OutputEncoder { + private static final Logger FRAME_LOGGER = LoggerFactory.getLogger("amqp.frame"); private static final AMQPDescribedTypeRegistry TYPE_REGISTRY = AMQPDescribedTypeRegistry.newInstance() .registerTransportLayer() .registerMessagingLayer() @@ -79,7 +83,9 @@ public class FrameEncoder implements OutputEncoder } }); - _frameWriter.send(((AMQFrame) msg)); + AMQFrame frame = (AMQFrame) msg; + FRAME_LOGGER.debug("SEND: " + frame.getFrameBody()); + _frameWriter.send(frame); int remaining = 0; for (ByteBuffer byteBuffer: buffers) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
