diff options
Diffstat (limited to 'weed/mq/topic/local_partition.go')
| -rw-r--r-- | weed/mq/topic/local_partition.go | 2 |
1 files changed, 1 insertions, 1 deletions
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{ |