Use quorum queues for higher reliability

Signed-off-by: Martin Domke <martin.domke@finleap.com>
finleap-connect · Dec 16, 2022 · 425a688 · 425a688
1 parent 0bee059
commit 425a688
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/eventsourcing/messaging/bus_rabbitmq.go b/pkg/eventsourcing/messaging/bus_rabbitmq.go
@@ -192,7 +192,7 @@ func (b *rabbitEventBus) addHandler(ctx context.Context, handler evs.EventHandle
 	if workQueueName == "" {
 		options = append(options, rabbitmq.WithConsumeOptionsQueueExclusive)
 	} else {
-		options = append(options, rabbitmq.WithConsumeOptionsQueueDurable)
+		options = append(options, rabbitmq.WithConsumeOptionsQueueDurable, rabbitmq.WithConsumeOptionsQuorum)
 	}
 
 	err := b.consumer.StartConsuming(