From 7b80080b786d0216471c6574bc19b8ecaed16ca1 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Tue, 28 Apr 2026 01:19:04 +0000 Subject: [PATCH 1/2] chore(deps): Bump rabbitmq Bumps rabbitmq from 4.2-management-alpine to 4.3-management-alpine. --- updated-dependencies: - dependency-name: rabbitmq dependency-version: 4.3-management-alpine dependency-type: direct:production ... Signed-off-by: dependabot[bot] --- springwolf-examples/springwolf-amqp-example/docker-compose.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/springwolf-examples/springwolf-amqp-example/docker-compose.yml b/springwolf-examples/springwolf-amqp-example/docker-compose.yml index 69923d65b..5e527f316 100644 --- a/springwolf-examples/springwolf-amqp-example/docker-compose.yml +++ b/springwolf-examples/springwolf-amqp-example/docker-compose.yml @@ -11,7 +11,7 @@ services: - amqp amqp: - image: rabbitmq:4.2-management-alpine + image: rabbitmq:4.3-management-alpine ports: # AMQP protocol port - '5672:5672' From 77675cd73f8cb829f7fa01ac33923008c28ab1e5 Mon Sep 17 00:00:00 2001 From: Timon Back Date: Sat, 2 May 2026 14:42:43 +0200 Subject: [PATCH 2/2] chore(amqp): remove deprecated amqp feature from example Transient (non-durable) non-exclusive classic queues are deprecated and cannot be declared by default starting with RabbitMQ 4.3.0. --- .../amqp/configuration/RabbitConfiguration.java | 10 ++++++---- .../examples/amqp/consumers/ExampleConsumer.java | 4 ++-- .../src/test/resources/asyncapi.json | 10 +++++----- .../src/test/resources/asyncapi.yaml | 10 +++++----- 4 files changed, 18 insertions(+), 16 deletions(-) diff --git a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/configuration/RabbitConfiguration.java b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/configuration/RabbitConfiguration.java index e773dac22..8627f308d 100644 --- a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/configuration/RabbitConfiguration.java +++ b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/configuration/RabbitConfiguration.java @@ -13,6 +13,8 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import java.util.Map; + @EnableRabbit @Configuration(proxyBeanMethods = false) public class RabbitConfiguration { @@ -25,17 +27,17 @@ public Jackson2JsonMessageConverter converter() { @Bean public Queue exampleQueue() { - return new Queue(AmqpConstants.QUEUE_EXAMPLE_QUEUE, false); + return new Queue(AmqpConstants.QUEUE_EXAMPLE_QUEUE, true, false, false); } @Bean public Queue anotherQueue() { - return new Queue(AmqpConstants.QUEUE_ANOTHER_QUEUE, false); + return new Queue(AmqpConstants.QUEUE_ANOTHER_QUEUE, true, false, true, Map.of("x-expires", 1800000)); } @Bean public Queue queueRead() { - return new Queue(AmqpConstants.QUEUE_READ, false); + return new Queue(AmqpConstants.QUEUE_READ, true, false, false); } @Bean @@ -53,7 +55,7 @@ public Queue multiPayloadQueue() { */ @Bean public Queue exampleBindingsQueue() { - return new Queue(AmqpConstants.QUEUE_EXAMPLE_BINDINGS_QUEUE, false, false, true); + return new Queue(AmqpConstants.QUEUE_EXAMPLE_BINDINGS_QUEUE, true, false, true); } /** diff --git a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java index 6d70c1db2..6ecc53b10 100644 --- a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java @@ -50,7 +50,7 @@ public void receiveAnotherPayload(AnotherPayloadDto payload) { value = @Queue( name = AmqpConstants.QUEUE_EXAMPLE_BINDINGS_QUEUE, - durable = "false", + durable = "true", exclusive = "false", autoDelete = "true"), key = AmqpConstants.ROUTING_KEY_EXAMPLE_TOPIC_ROUTING_KEY) @@ -125,7 +125,7 @@ public void bindingsUpdate(Message message, @Payload GenericPayloadDto