From b23ab2dfe2a8d835f7ae93dbf4acfffcb0db6d5f Mon Sep 17 00:00:00 2001
From: James Magahern <james@magahern.com>
Date: Tue, 19 Mar 2024 01:34:33 -0700
Subject: [PATCH] ChatRepository: Removing from message queue should block

---
 .../net/buzzert/kordophone/backend/server/ChatRepository.kt     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt b/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt
index 141822f..182e818 100644
--- a/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt
+++ b/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt
@@ -236,7 +236,7 @@ class ChatRepository(
     private fun outgoingMessageQueueMain() {
         Log.d(REPO_LOG, "Outgoing Message Queue Main")
         while (true) {
-            val outgoingMessageRequest = outgoingMessageQueue.poll()?.let {
+            val outgoingMessageRequest = outgoingMessageQueue.take().let {
                 runBlocking {
                     val outgoingMessage = it.message
                     val conversation = it.conversation