Fix: api comments (#867)

apache · Jul 25, 2022 · 595f2d9 · 595f2d9
1 parent 159ac27
commit 595f2d9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/api.go b/api.go
@@ -54,10 +54,10 @@ func NewTransactionProducer(listener primitive.TransactionListener, opts ...prod
 }
 
 type PushConsumer interface {
-	// Start the PullConsumer for consuming message
+	// Start the PushConsumer for consuming message
 	Start() error
 
-	// 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
 	Shutdown() error
 	// Subscribe a topic for consuming
 	Subscribe(topic string, selector consumer.MessageSelector,