This is an automated email from the ASF dual-hosted git repository.
tabish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-protonj2.git
The following commit(s) were added to refs/heads/main by this push:
new bb2d2de PROTON-2380 Show difference of SASL vs AMQP default header in
logs
bb2d2de is described below
commit bb2d2de973c6aa268f367deac2bdee48a5710130
Author: Timothy Bish <[email protected]>
AuthorDate: Thu May 6 15:12:35 2021 -0400
PROTON-2380 Show difference of SASL vs AMQP default header in logs
---
.../qpid/protonj2/engine/impl/ProtonFrameLoggingHandler.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonFrameLoggingHandler.java
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonFrameLoggingHandler.java
index cf07ea0..7993c07 100644
---
a/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonFrameLoggingHandler.java
+++
b/protonj2/src/main/java/org/apache/qpid/protonj2/engine/impl/ProtonFrameLoggingHandler.java
@@ -59,14 +59,14 @@ public class ProtonFrameLoggingHandler implements
EngineHandler {
}
@Override
- public void handleRead(EngineHandlerContext context, HeaderEnvelope
header) {
+ public void handleRead(EngineHandlerContext context, HeaderEnvelope
envelope) {
if (traceFrames) {
- trace(AMQP_IN_PREFIX, 0, header.getBody(), null);
+ trace(envelope.isSaslHeader() ? SASL_OUT_PREFIX : AMQP_OUT_PREFIX,
0, envelope.getBody(), null);
}
- log(AMQP_IN_PREFIX, 0, header.getBody(), null);
+ log(envelope.isSaslHeader() ? SASL_OUT_PREFIX : AMQP_OUT_PREFIX, 0,
envelope.getBody(), null);
- context.fireRead(header);
+ context.fireRead(envelope);
}
@Override
@@ -96,10 +96,10 @@ public class ProtonFrameLoggingHandler implements
EngineHandler {
@Override
public void handleWrite(EngineHandlerContext context, HeaderEnvelope
envelope) {
if (traceFrames) {
- trace(AMQP_OUT_PREFIX, 0, envelope.getBody(), null);
+ trace(envelope.isSaslHeader() ? SASL_OUT_PREFIX : AMQP_OUT_PREFIX,
0, envelope.getBody(), null);
}
- log(AMQP_OUT_PREFIX, 0, envelope.getBody(), null);
+ log(envelope.isSaslHeader() ? SASL_OUT_PREFIX : AMQP_OUT_PREFIX, 0,
envelope.getBody(), null);
context.fireWrite(envelope);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
