diff --git a/app/conf/config.go b/app/conf/config.go index 52ab81b..843896c 100644 --- a/app/conf/config.go +++ b/app/conf/config.go @@ -129,6 +129,9 @@ func LoadYamlConfig(filename string, env string) []string { err := setQueueRedrivePolicy(models.SyncQueues.Queues, q, queue.RedrivePolicy) if err != nil { log.Errorf("err: %s", err) + // Разблокировать глобальный мьютекс перед выходом — иначе все + // операции с очередями зависнут навсегда (deadlock). + models.SyncQueues.Unlock() return ports } }