Browse Source

解决撤回消息中原消息中二进制消息数据格式错误问题

heavyrian2012 2 years ago
parent
commit
932ee9235f

+ 1 - 1
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java

@@ -2278,7 +2278,7 @@ public class MemoryMessagesStore implements IMessagesStore {
             json.put("c", message.getContent().getContent());
             json.put("e", message.getContent().getExtra());
             if (message.getContent().getData() != null && message.getContent().getData().size() > 0) {
-                json.put("b", Base64.getEncoder().encode(message.getContent().getData().toByteArray()));
+                json.put("b", Base64.getEncoder().encodeToString(message.getContent().getData().toByteArray()));
             }
             if (message.getContent().getMediaType() > 0) {
                 json.put("mt", message.getContent().getMediaType());