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