diff --git a/pkg/mq/rabbitmq.go b/pkg/mq/rabbitmq.go
index 8a1290b..cd928df 100644
--- a/pkg/mq/rabbitmq.go
+++ b/pkg/mq/rabbitmq.go
@@ -64,7 +64,7 @@ func (r *rabbitMQ) Consume(ctx context.Context, messageHandler func(ctx context.
 
 		q, err := ch.QueueDeclare(
 			r.queueName, // name
-			false,       // durable
+			true,        // durable
 			false,       // delete when unused
 			false,       // exclusive
 			false,       // no-wait