diff options
Diffstat (limited to 'modules/queue/unique_queue_disk_channel.go')
| -rw-r--r-- | modules/queue/unique_queue_disk_channel.go | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/modules/queue/unique_queue_disk_channel.go b/modules/queue/unique_queue_disk_channel.go index af42c0913d..d71f5e2b04 100644 --- a/modules/queue/unique_queue_disk_channel.go +++ b/modules/queue/unique_queue_disk_channel.go @@ -197,7 +197,6 @@ func (q *PersistableChannelUniqueQueue) Run(atShutdown, atTerminate func(func()) q.internal.(*LevelUniqueQueue).Shutdown() GetManager().Remove(q.internal.(*LevelUniqueQueue).qid) } - } // Flush flushes the queue |