From f8787a9761fd190e0c2d10e4af818ede1e174e3d Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Fri, 5 Jan 2024 15:16:41 -0800
Subject: [PATCH] rename functions

---
 weed/mq/client/sub_client/connect_to_sub_coordinator.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/weed/mq/client/sub_client/connect_to_sub_coordinator.go b/weed/mq/client/sub_client/connect_to_sub_coordinator.go
index 51b8b1f8c..64e49092c 100644
--- a/weed/mq/client/sub_client/connect_to_sub_coordinator.go
+++ b/weed/mq/client/sub_client/connect_to_sub_coordinator.go
@@ -131,9 +131,9 @@ func (sub *TopicSubscriber) onEachPartition(partition *mq_pb.Partition, broker s
 			defer sub.OnCompletionFunc()
 		}
 		defer func() {
-			subscribeClient.SendMsg(&mq_pb.SubscribeRequest{
-				Message: &mq_pb.SubscribeRequest_Ack{
-					Ack: &mq_pb.SubscribeRequest_AckMessage{
+			subscribeClient.SendMsg(&mq_pb.SubscribeMessageRequest{
+				Message: &mq_pb.SubscribeMessageRequest_Ack{
+					Ack: &mq_pb.SubscribeMessageRequest_AckMessage{
 						Sequence: 0,
 					},
 				},