Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #3485

This commit is contained in:
Justin Bertram 2021-03-17 09:53:22 -05:00
parent d718a9dd32 e1669d4ad2
commit cd44d90f2b
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompFrame.java
View File

@ -20,6 +20,7 @@ import java.nio.charset.StandardCharsets;
import java.util.Arrays; import java.util.Arrays;
import java.util.LinkedHashMap; import java.util.LinkedHashMap;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors;
import org.apache.activemq.artemis.api.core.ActiveMQBuffer; import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
import org.apache.activemq.artemis.api.core.ActiveMQBuffers; import org.apache.activemq.artemis.api.core.ActiveMQBuffers;
@ -79,7 +80,11 @@ public class StompFrame {
public String toString() { public String toString() {
StringBuilder result = new StringBuilder() StringBuilder result = new StringBuilder()
.append("StompFrame[command=").append(command) .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)) { if (command.equals(Stomp.Responses.MESSAGE) || command.equals(Stomp.Responses.ERROR) || command.equals(Stomp.Commands.SEND)) {
result.append(", body=").append(this.getBody()) result.append(", body=").append(this.getBody())