diff --git a/pkg/eventsourcing/messaging/bus_rabbitmq.go b/pkg/eventsourcing/messaging/bus_rabbitmq.go
index 2ce4016ee..95dc5fb9a 100644
--- a/pkg/eventsourcing/messaging/bus_rabbitmq.go
+++ b/pkg/eventsourcing/messaging/bus_rabbitmq.go
@@ -191,6 +191,8 @@ func (b *rabbitEventBus) addHandler(ctx context.Context, handler evs.EventHandle
 	}
 	if workQueueName == "" {
 		options = append(options, rabbitmq.WithConsumeOptionsQueueExclusive)
+	} else {
+		options = append(options, rabbitmq.WithConsumeOptionsQueueDurable)
 	}
 
 	err := b.consumer.StartConsuming(