[rocketmq-client-go] branch master updated: fix: selectMessageQueue nil *internal.TopicPublishInfo

[du...@apache.org]

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

duhengforever 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 88b1b05  fix: selectMessageQueue nil *internal.TopicPublishInfo
     new f56028f  Merge pull request #857 from weedge/fix/selectMessageQueue_nil
88b1b05 is described below

commit 88b1b057e35a8effc14ff348b9f08723e3476b95
Author: weedge <we...@gmail.com>
AuthorDate: Mon Jul 18 22:21:04 2022 +0800

    fix: selectMessageQueue nil *internal.TopicPublishInfo
---
 producer/producer.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/producer/producer.go b/producer/producer.go
index 5ebf5d0..1aef69a 100644
--- a/producer/producer.go
+++ b/producer/producer.go
@@ -533,6 +533,9 @@ func (p *defaultProducer) tryToFindTopicPublishInfo(topic string) *internal.Topi
 func (p *defaultProducer) selectMessageQueue(msg *primitive.Message) *primitive.MessageQueue {
 	topic := msg.Topic
 	result := p.tryToFindTopicPublishInfo(topic)
+	if result == nil {
+		return nil
+	}
 	return p.options.Selector.Select(msg, result.MqList)
 }