From 595f2d92d9ac3b7b03f4c9f1fc8d4b30053d2912 Mon Sep 17 00:00:00 2001
From: Laurence <45508533+LaurenceLiZhixin@users.noreply.github.com>
Date: Mon, 25 Jul 2022 16:12:14 +0800
Subject: [PATCH] Fix: api comments (#867)

---
 api.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/api.go b/api.go
index 4dd05aa8..6a39c289 100644
--- 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,