You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/05/26 05:47:56 UTC
[rocketmq-client-go] branch master updated: fix async producer example
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 2d8ce82 fix async producer example
new 1f541f7 Merge pull request #809 from yuz10/master
2d8ce82 is described below
commit 2d8ce820de248c6e1f1156b8eb9cdfd4a6121dbb
Author: yuz10 <84...@qq.com>
AuthorDate: Fri Apr 15 00:27:56 2022 +0800
fix async producer example
---
examples/producer/async/main.go | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/examples/producer/async/main.go b/examples/producer/async/main.go
index 2a5182c..e225214 100644
--- a/examples/producer/async/main.go
+++ b/examples/producer/async/main.go
@@ -32,8 +32,7 @@ import (
func main() {
p, _ := rocketmq.NewProducer(
producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"127.0.0.1:9876"})),
- producer.WithRetry(2),
- producer.WithQueueSelector(producer.NewManualQueueSelector()))
+ producer.WithRetry(2))
err := p.Start()
if err != nil {