From f794a909baeb978de7e940feb332c435de19436b Mon Sep 17 00:00:00 2001 From: Bart Koelman <104792814+bart-vmware@users.noreply.github.com> Date: Wed, 3 Jun 2026 11:24:17 +0200 Subject: [PATCH] RabbitMQ: Use durable queues While sample works with docker image `rabbitmq:3-management`, it fails with `rabbitmq:latest`: > RabbitMQ.Client.Exceptions.OperationInterruptedException: 'The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=541, text='INTERNAL_ERROR - Feature `transient_nonexcl_queues` is deprecated. By default, this feature is not permitted anymore. The feature will be removed from a future major RabbitMQ version, regardless of the configuration; actual version to be determined. To...', classId=50, methodId=10' --- Connectors/src/RabbitMQ/Controllers/HomeController.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Connectors/src/RabbitMQ/Controllers/HomeController.cs b/Connectors/src/RabbitMQ/Controllers/HomeController.cs index 0fb772c32..3947c504e 100644 --- a/Connectors/src/RabbitMQ/Controllers/HomeController.cs +++ b/Connectors/src/RabbitMQ/Controllers/HomeController.cs @@ -83,7 +83,7 @@ public async Task Receive(CancellationToken cancellationToken) private static async Task CreateQueueAsync(IChannel channel, CancellationToken cancellationToken) { await channel.ExchangeDeclareAsync(RabbitExchangeName, ExchangeType.Direct, cancellationToken: cancellationToken); - await channel.QueueDeclareAsync(RabbitQueueName, false, false, false, cancellationToken: cancellationToken); + await channel.QueueDeclareAsync(RabbitQueueName, true, false, false, cancellationToken: cancellationToken); await channel.QueueBindAsync(RabbitQueueName, RabbitExchangeName, RabbitRoutingKey, cancellationToken: cancellationToken); }