From 531f854af2d0094138cec84b05e0829f50291b15 Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 5 Jan 2024 15:16:53 -0800 Subject: [PATCH] rename functions --- weed/mq/client/sub_client/connect_to_sub_coordinator.go | 4 ++-- 1 file changed, 2 insertions(+), 2 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 64e49092c..e7749f94b 100644 --- a/weed/mq/client/sub_client/connect_to_sub_coordinator.go +++ b/weed/mq/client/sub_client/connect_to_sub_coordinator.go @@ -151,7 +151,7 @@ func (sub *TopicSubscriber) onEachPartition(partition *mq_pb.Partition, broker s continue } switch m := resp.Message.(type) { - case *mq_pb.SubscribeResponse_Data: + case *mq_pb.SubscribeMessageResponse_Data: shouldContinue, processErr := sub.OnEachMessageFunc(m.Data.Key, m.Data.Value) if processErr != nil { return fmt.Errorf("process error: %v", processErr) @@ -160,7 +160,7 @@ func (sub *TopicSubscriber) onEachPartition(partition *mq_pb.Partition, broker s if !shouldContinue { return nil } - case *mq_pb.SubscribeResponse_Ctrl: + case *mq_pb.SubscribeMessageResponse_Ctrl: if m.Ctrl.IsEndOfStream || m.Ctrl.IsEndOfTopic { return io.EOF }