From d3c0edc9baab126d61f42cd1aad1a2d61a4b0054 Mon Sep 17 00:00:00 2001 From: chrislu Date: Wed, 26 Feb 2025 00:32:49 -0800 Subject: [PATCH] purge unused --- weed/mq/client/sub_client/subscriber.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/weed/mq/client/sub_client/subscriber.go b/weed/mq/client/sub_client/subscriber.go index 911f3a318..8f4a47c62 100644 --- a/weed/mq/client/sub_client/subscriber.go +++ b/weed/mq/client/sub_client/subscriber.go @@ -34,7 +34,6 @@ type TopicSubscriber struct { OnDataMessageFunc OnDataMessageFn OnCompletionFunc OnCompletionFunc bootstrapBrokers []string - waitForMoreMessage bool activeProcessors map[topic.Partition]*ProcessorState activeProcessorsLock sync.Mutex PartitionOffsetChan chan KeyedOffset @@ -47,7 +46,6 @@ func NewTopicSubscriber(bootstrapBrokers []string, subscriber *SubscriberConfigu brokerPartitionAssignmentChan: make(chan *mq_pb.SubscriberToSubCoordinatorResponse, 1024), brokerPartitionAssignmentAckChan: make(chan *mq_pb.SubscriberToSubCoordinatorRequest, 1024), bootstrapBrokers: bootstrapBrokers, - waitForMoreMessage: true, activeProcessors: make(map[topic.Partition]*ProcessorState), PartitionOffsetChan: partitionOffsetChan, }