diff options
Diffstat (limited to 'weed/mq/topic/local_partition_subscribers.go')
| -rw-r--r-- | weed/mq/topic/local_partition_subscribers.go | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/weed/mq/topic/local_partition_subscribers.go b/weed/mq/topic/local_partition_subscribers.go index e177ec7e8..caadff278 100644 --- a/weed/mq/topic/local_partition_subscribers.go +++ b/weed/mq/topic/local_partition_subscribers.go @@ -47,3 +47,10 @@ func (p *LocalPartitionSubscribers) SignalShutdown() { Subscriber.SignalShutdown() } } + +func (p *LocalPartitionSubscribers) IsEmpty() bool { + p.SubscribersLock.RLock() + defer p.SubscribersLock.RUnlock() + + return len(p.Subscribers) == 0 +} |