Commit 762d189c authored by Orne Brocaar's avatar Orne Brocaar
Browse files

Restore the AMQP queue if needed after a connection failure.

Closes #503.
parent 4e7fdb34
......@@ -277,6 +277,11 @@ func (b *Backend) eventLoop() {
// (in the loop).
log.WithError(err).Error("gateway/amqp: event loop error")
time.Sleep(time.Second)
// Restore the queue if needed.
if err := b.setupQueue(); err != nil {
log.WithError(err).Error("gateway/amqp: setup queue error")
}
}
}
}
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment