Skip to content

Commit 2d8ce82

Browse files
committed
fix async producer example
1 parent 7cd7fa9 commit 2d8ce82

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

examples/producer/async/main.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,7 @@ import (
3232
func main() {
3333
p, _ := rocketmq.NewProducer(
3434
producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"127.0.0.1:9876"})),
35-
producer.WithRetry(2),
36-
producer.WithQueueSelector(producer.NewManualQueueSelector()))
35+
producer.WithRetry(2))
3736

3837
err := p.Start()
3938
if err != nil {

0 commit comments

Comments
 (0)