fix

9 months ago · 2a0ab7e90d
1 changed files with 1 additions and 1 deletions
--- 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{