From 6b9c3c9195089a183ee424fa0d6c6460e8052729 Mon Sep 17 00:00:00 2001 From: xiaolibuzai <3163678221@qq.com> Date: Mon, 11 Sep 2023 16:45:48 +0800 Subject: [PATCH] [ISSUE #1046] fix build replay message lose body --- consumer/message_util.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer/message_util.go b/consumer/message_util.go index bde33773..87129d2b 100644 --- a/consumer/message_util.go +++ b/consumer/message_util.go @@ -42,7 +42,7 @@ func CreateReplyMessage(requestMessage *primitive.MessageExt, body []byte) (*pri var replayMessage primitive.Message - replayMessage.UnmarshalProperties(body) + replayMessage.Body = body replayMessage.Topic = internal.GetReplyTopic(cluster) replayMessage.WithProperty(primitive.PropertyMsgType, internal.ReplyMessageFlag) replayMessage.WithProperty(primitive.PropertyCorrelationID, correlationId)