From e1669d4ad2161352cd8118215eaefec2aadadeb0 Mon Sep 17 00:00:00 2001 From: Justin Bertram Date: Wed, 10 Mar 2021 09:24:10 -0600 Subject: [PATCH] ARTEMIS-3172 don't log STOMP CONNECT passcode header --- .../activemq/artemis/core/protocol/stomp/StompFrame.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompFrame.java b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompFrame.java index aa921ddec4..a48ac3a26a 100644 --- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompFrame.java +++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompFrame.java @@ -20,6 +20,7 @@ import java.nio.charset.StandardCharsets; import java.util.Arrays; import java.util.LinkedHashMap; import java.util.Map; +import java.util.stream.Collectors; import org.apache.activemq.artemis.api.core.ActiveMQBuffer; import org.apache.activemq.artemis.api.core.ActiveMQBuffers; @@ -79,7 +80,11 @@ public class StompFrame { public String toString() { StringBuilder result = new StringBuilder() .append("StompFrame[command=").append(command) - .append(", headers=").append(headers); + .append(", headers=").append(headers + .keySet() + .stream() + .map(key -> key + "=" + (key.equals(Stomp.Headers.Connect.PASSCODE) ? "****" : headers.get(key))) + .collect(Collectors.joining(", ", "{", "}"))); if (command.equals(Stomp.Responses.MESSAGE) || command.equals(Stomp.Responses.ERROR) || command.equals(Stomp.Commands.SEND)) { result.append(", body=").append(this.getBody())