rename functions

1 year ago · f8787a9761
1 changed files with 3 additions and 3 deletions
--- 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,
 					},
 				},