feat: Birth messages now default to Qos 1

Signed-off-by: MMaiero <[email protected]>
eclipse-kura · Oct 2, 2023 · 7280e98 · 7280e98
1 parent ef48678
commit 7280e98
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...clipse.kura.core.cloud/src/main/java/org/eclipse/kura/core/cloud/CloudServiceOptions.java b/...clipse.kura.core.cloud/src/main/java/org/eclipse/kura/core/cloud/CloudServiceOptions.java
@@ -42,7 +42,7 @@ public class CloudServiceOptions {
     private static final String ENABLE_DFLT_SUBSCRIPTIONS = "enable.default.subscriptions";
     private static final String PAYLOAD_ENCODING = "payload.encoding";
 
-    private static final int LIFECYCLE_QOS = 0;
+    private static final int LIFECYCLE_QOS = 1;
     private static final int LIFECYCLE_PRIORITY = 0;
     private static final boolean LIFECYCLE_RETAIN = false;
 

diff --git a/...pse.kura.core.cloud.test/src/test/java/org/eclipse/kura/core/cloud/BirthMessagesTest.java b/...pse.kura.core.cloud.test/src/test/java/org/eclipse/kura/core/cloud/BirthMessagesTest.java
@@ -394,12 +394,12 @@ private void thenNoBirthIsPublished() throws KuraStoreException {
     private void thenBirthIsPublishedAfter(long delayMillis, String expectedTopic) throws KuraException {
         verify(this.dataService, after(delayMillis).never()).publish(eq(expectedTopic), any(), eq(0), eq(false),
                 eq(0));
-        verify(this.dataService, after(delayMillis + SLACK_DELAY).times(1)).publish(eq(expectedTopic), any(), eq(0),
+        verify(this.dataService, after(delayMillis + SLACK_DELAY).times(1)).publish(eq(expectedTopic), any(), eq(1),
                 eq(false), eq(0));
     }
 
     private void thenBirthIsPublishedImmediately(String expectedTopic) throws KuraException {
-        verify(this.dataService, timeout(SLACK_DELAY).times(1)).publish(eq(expectedTopic), any(), eq(0), eq(false),
+        verify(this.dataService, timeout(SLACK_DELAY).times(1)).publish(eq(expectedTopic), any(), eq(1), eq(false),
                 eq(0));
     }