Restore the AMQP queue if needed after a connection failure.

Closes #503.
brocaar · Oct 19, 2021 · 762d189 · 762d189
1 parent 4e7fdb3
commit 762d189
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/internal/backend/gateway/amqp/amqp.go b/internal/backend/gateway/amqp/amqp.go
@@ -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")
+			}
 		}
 	}
 }