Feature/amqp single consumers (#373)

* Use quorum queues instead of classic queues * Configure amqp queue to use x-single-active-consumer to allow the server component to run in HA mode while still only handling one message at a time
lunarway · Jun 16, 2022 · 13734da · 13734da
1 parent 24787e8
commit 13734da
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/amqp/consumer.go b/internal/amqp/consumer.go
@@ -122,7 +122,8 @@ func (w *Worker) initializeConsumer(c ConsumerConfig) error {
 
 	w.logger.Infof("[amqp] Declaring queue '%s'", prefixedQueue)
 	queueArgs := amqp.Table{
-		"x-queue-type": "quorum",
+		"x-queue-type":             "quorum",
+		"x-single-active-consumer": true,
 	}
 	_, err = channel.QueueDeclare(
 		prefixedQueue,   // name