[rocketmq-client-go] branch master updated: fix:logic error when reset retry message's origin topic (#971)

[cserwen]

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

cserwen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new a2cf953  fix:logic error when reset retry message's origin topic (#971)
a2cf953 is described below

commit a2cf953d838f1ef10f5b43381da3dff05c99d3ca
Author: Humkum <1109939...@qq.com>
AuthorDate: Fri Feb 10 10:57:23 2023 +0800

    fix:logic error when reset retry message's origin topic (#971)
---
 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 a3366e6..7d585de 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -1054,7 +1054,7 @@ func (pc *pushConsumer) resetRetryAndNamespace(subMsgs 
[]*primitive.MessageExt)
        for idx := range subMsgs {
                msg := subMsgs[idx]
                retryTopic := msg.GetProperty(primitive.PropertyRetryTopic)
-               if retryTopic == "" && groupTopic == msg.Topic {
+               if retryTopic != "" && groupTopic == msg.Topic {
                        msg.Topic = retryTopic
                }
                subMsgs[idx].WithProperty(primitive.PropertyConsumeStartTime, 
strconv.FormatInt(