From bc21d5cf25e2281e86cf4fedba4c8db4f98eaeb1 Mon Sep 17 00:00:00 2001 From: WJL3333 Date: Sat, 23 Jul 2022 18:45:54 +0800 Subject: [PATCH] avoid sendmessage back with origin message body in request. --- consumer/push_consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go index 3221c6c9..1cae43c8 100644 --- a/consumer/push_consumer.go +++ b/consumer/push_consumer.go @@ -847,7 +847,7 @@ func (pc *pushConsumer) buildSendBackRequest(msg *primitive.MessageExt, delayLev MaxReconsumeTimes: pc.getMaxReconsumeTimes(), } - return remote.NewRemotingCommand(internal.ReqConsumerSendMsgBack, req, msg.Body) + return remote.NewRemotingCommand(internal.ReqConsumerSendMsgBack, req, nil) } func (pc *pushConsumer) suspend() {