chore(deps): Bump rabbitmq from 4.2-management-alpine to 4.3-management-alpine in /springwolf-examples/springwolf-amqp-example

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'

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);
     }
 
     /**

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<ExamplePa
                                             name = AmqpConstants.EXCHANGE_CRUD_TOPIC_EXCHANGE_2,
                                             type = ExchangeTypes.TOPIC),
                             key = AmqpConstants.ROUTING_KEY_ALL_MESSAGES,
-                            value = @Queue(name = AmqpConstants.QUEUE_READ, durable = "false", autoDelete = "false")))
+                            value = @Queue(name = AmqpConstants.QUEUE_READ, durable = "true", autoDelete = "false")))
     public void bindingsRead(Message message, @Payload ExamplePayloadDto payload) {
         log.debug(
                 "Received new message {} in {} (ExamplePayloadDto): {}",

springwolf-examples/springwolf-amqp-example/src/test/resources/asyncapi.json

@@ -80,9 +80,9 @@
           "is": "queue",
           "queue": {
             "name": "another-queue",
-            "durable": false,
+            "durable": true,
             "exclusive": false,
-            "autoDelete": false,
+            "autoDelete": true,
             "vhost": "/"
           },
           "bindingVersion": "0.3.0"
@@ -96,7 +96,7 @@
           "is": "queue",
           "queue": {
             "name": "example-bindings-queue",
-            "durable": false,
+            "durable": true,
             "exclusive": false,
             "autoDelete": true,
             "vhost": "/"
@@ -117,7 +117,7 @@
           "is": "queue",
           "queue": {
             "name": "example-queue",
-            "durable": false,
+            "durable": true,
             "exclusive": false,
             "autoDelete": false,
             "vhost": "/"
@@ -229,7 +229,7 @@
           "is": "queue",
           "queue": {
             "name": "queue-read",
-            "durable": false,
+            "durable": true,
             "exclusive": false,
             "autoDelete": false,
             "vhost": "/"

springwolf-examples/springwolf-amqp-example/src/test/resources/asyncapi.yaml

@@ -61,9 +61,9 @@ channels:
         is: queue
         queue:
           name: another-queue
-          durable: false
+          durable: true
           exclusive: false
-          autoDelete: false
+          autoDelete: true
           vhost: /
         bindingVersion: 0.3.0
   example-bindings-queue:
@@ -73,7 +73,7 @@ channels:
         is: queue
         queue:
           name: example-bindings-queue
-          durable: false
+          durable: true
           exclusive: false
           autoDelete: true
           vhost: /
@@ -88,7 +88,7 @@ channels:
         is: queue
         queue:
           name: example-queue
-          durable: false
+          durable: true
           exclusive: false
           autoDelete: false
           vhost: /
@@ -168,7 +168,7 @@ channels:
         is: queue
         queue:
           name: queue-read
-          durable: false
+          durable: true
           exclusive: false
           autoDelete: false
           vhost: /