Adds priority property to message and sorts local store by priority.

customerio · Nov 7, 2023 · 3bd4851 · 3bd4851
1 parent 4a4d885
commit 3bd4851
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/messaginginapp/src/main/java/io/customer/messaginginapp/gist/data/listeners/Queue.kt b/messaginginapp/src/main/java/io/customer/messaginginapp/gist/data/listeners/Queue.kt
@@ -143,7 +143,9 @@ class Queue : GistListener {
     }
 
     private fun handleMessages(messages: List<Message>) {
-        for (message in messages) {
+        // Sorting messages by priority and placing nulls last.
+        val sortedMessages = messages.sortedWith(compareBy(nullsLast()) { it.priority })
+        for (message in sortedMessages) {
             processMessage(message)
         }
     }

diff --git a/messaginginapp/src/main/java/io/customer/messaginginapp/gist/data/model/Message.kt b/messaginginapp/src/main/java/io/customer/messaginginapp/gist/data/model/Message.kt
@@ -18,6 +18,7 @@ data class GistProperties(
 data class Message(
     val messageId: String = "",
     val instanceId: String = UUID.randomUUID().toString(),
+    val priority: Int? = null,
     val queueId: String? = null,
     val properties: Map<String, Any?>? = null
 )