diff --git a/src/Transports/RabbitMQ/Wolverine.RabbitMQ/RabbitMqBinding.cs b/src/Transports/RabbitMQ/Wolverine.RabbitMQ/RabbitMqBinding.cs index d8770551b..d8be877dc 100644 --- a/src/Transports/RabbitMQ/Wolverine.RabbitMQ/RabbitMqBinding.cs +++ b/src/Transports/RabbitMQ/Wolverine.RabbitMQ/RabbitMqBinding.cs @@ -24,10 +24,6 @@ public RabbitMqBinding(string exchangeName, RabbitMqQueue queue, string? binding internal async Task DeclareAsync(IChannel channel, ILogger logger) { - if (HasDeclared) - { - return; - } await channel.QueueBindAsync(_queue.EndpointName, ExchangeName, BindingKey, Arguments); logger.LogInformation("Declared a Rabbit Mq binding '{Key}' from exchange {Exchange} to {Queue}", BindingKey, ExchangeName, _queue.EndpointName); @@ -75,4 +71,4 @@ public override string ToString() return $"{nameof(BindingKey)}: {BindingKey}, {nameof(Queue)}: {Queue}, {nameof(ExchangeName)}: {ExchangeName}"; } -} \ No newline at end of file +}