Merge pull request #9 from netz39/durable-messages

✨ Make messages durable
netz39 · Sep 6, 2022 · 72d65d8 · 72d65d8
2 parents a8c51b0 + d591115
commit 72d65d8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/de/netz39/svc/pwrMtrPlsGw/AmqpEmitter.java b/src/main/java/de/netz39/svc/pwrMtrPlsGw/AmqpEmitter.java
@@ -7,6 +7,7 @@
 @RabbitClient
 public interface AmqpEmitter {
     @RabbitProperty(name = "contentType", value = "application/json")
+    @RabbitProperty(name = "deliveryMode", value = "2") // Durable messages
     void send(@Binding String destination,
               PulseMessage pulseMessage);
 }