From 2a0ab7e90d728ffbab89300e72075d8b35bc54a3 Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Wed, 27 Mar 2024 22:59:50 -0700
Subject: [PATCH] fix

---
 weed/mq/topic/local_partition.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go
index 3c902a503..53324d846 100644
--- a/weed/mq/topic/local_partition.go
+++ b/weed/mq/topic/local_partition.go
@@ -179,7 +179,7 @@ func (p *LocalPartition) MaybeConnectToFollowers(initMessage *mq_pb.PublishMessa
 }
 
 func (p *LocalPartition) MaybeShutdownLocalPartition() (hasShutdown bool) {
-	if p.MaybeShutdownLocalPartition() {
+	if p.canShutdownLocalPartition() {
 		if p.FollowerStream != nil {
 			// send close to the follower
 			if followErr := p.FollowerStream.Send(&mq_pb.PublishFollowMeRequest{