зеркало из https://github.com/mozilla/mig.git
[minor] log queue cleanup as info instead of debug
This commit is contained in:
Родитель
d7ce05d15a
Коммит
91985e262d
|
@ -2,9 +2,10 @@ package main
|
|||
|
||||
import (
|
||||
"fmt"
|
||||
"time"
|
||||
|
||||
"github.com/streadway/amqp"
|
||||
"mig.ninja/mig"
|
||||
"time"
|
||||
)
|
||||
|
||||
// QueuesCleanup deletes rabbitmq queues of endpoints that no
|
||||
|
@ -44,7 +45,7 @@ func QueuesCleanup(ctx Context) (err error) {
|
|||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
ctx.Channels.Log <- mig.Log{OpID: ctx.OpID, Desc: fmt.Sprintf("QueuesCleanup(): found %d offline endpoints between %s and now", len(queues), oldest.String())}.Debug()
|
||||
ctx.Channels.Log <- mig.Log{OpID: ctx.OpID, Desc: fmt.Sprintf("QueuesCleanup(): found %d offline endpoints between %s and now", len(queues), oldest.String())}
|
||||
makeamqpchan := true
|
||||
for _, queue := range queues {
|
||||
if makeamqpchan {
|
||||
|
|
Загрузка…
Ссылка в новой задаче