diff --git a/internal/events/rabbitmq/consumer/declares.go b/internal/events/rabbitmq/consumer/declares.go index 5eb1e4a..b5a4d00 100644 --- 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,