remove passive

gothunder · Dec 5, 2024 · a8c1835 · a8c1835
1 parent 5de0cc1
commit a8c1835
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/events/rabbitmq/consumer/declares.go b/internal/events/rabbitmq/consumer/declares.go
@@ -98,7 +98,7 @@ func (r *rabbitmqConsumer) deadLetterDeclare(dlxName string) error {
 		return eris.Wrap(err, "failed to declare exchange")
 	}
 
-	_, err = r.chManager.Channel.QueueDeclarePassive(
+	_, err = r.chManager.Channel.QueueDeclare(
 		dlxName,
 		true,
 		false,