diff --git a/pkg/eventsourcing/messaging/bus_rabbitmq.go b/pkg/eventsourcing/messaging/bus_rabbitmq.go
index 95dc5fb9..24edb8f5 100644
--- 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(