We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 159ac27 commit 595f2d9Copy full SHA for 595f2d9
api.go
@@ -54,10 +54,10 @@ func NewTransactionProducer(listener primitive.TransactionListener, opts ...prod
54
}
55
56
type PushConsumer interface {
57
- // Start the PullConsumer for consuming message
+ // Start the PushConsumer for consuming message
58
Start() error
59
60
- // Shutdown the PullConsumer, all offset of MessageQueue will be sync to broker before process exit
+ // Shutdown the PushConsumer, all offset of MessageQueue will be sync to broker before process exit
61
Shutdown() error
62
// Subscribe a topic for consuming
63
Subscribe(topic string, selector consumer.MessageSelector,
0 commit comments