[rocketmq-mqtt] branch develop updated: Fix the error about empty retained message

[pingww]

This is an automated email from the ASF dual-hosted git repository.

pingww pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git


The following commit(s) were added to refs/heads/develop by this push:
     new fd6c137  Fix the error about empty retained message
     new f7cad0e  Merge pull request #175 from YYYYWD/develop
fd6c137 is described below

commit fd6c1374f0d9e6dfd13b0482b2afffecfd9f91b7
Author: yyyywd <278580...@qq.com>
AuthorDate: Tue Jan 17 23:44:05 2023 +0800

    Fix the error about empty retained message
---
 .../rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java
 
b/mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java
index b8b662b..370e771 100644
--- 
a/mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java
+++ 
b/mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java
@@ -63,6 +63,9 @@ public class RetainedMsgStateProcessor extends StateProcessor 
{
 
             if (operation.equals("topic")) {    //return retained msg
                 byte[] msgBytes = retainedMsgMap.get(topic);
+                if (msgBytes == null) {
+                    msgBytes = "null".getBytes();
+                }
                 return Response.newBuilder()
                     .setSuccess(true)
                     .setData(ByteString.copyFrom(msgBytes))