From 5102f5215c00a00db6349f7fe834f6164d6e0e95 Mon Sep 17 00:00:00 2001
From: Greyson Parrelli <greyson@signal.org>
Date: Tue, 21 Dec 2021 15:07:13 -0500
Subject: [PATCH] Use proper processing queue for sync messages.

---
 .../org/thoughtcrime/securesms/jobs/PushProcessMessageJob.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/app/src/main/java/org/thoughtcrime/securesms/jobs/PushProcessMessageJob.java b/app/src/main/java/org/thoughtcrime/securesms/jobs/PushProcessMessageJob.java
index 9187dd0932..a06b587e22 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/jobs/PushProcessMessageJob.java
+++ b/app/src/main/java/org/thoughtcrime/securesms/jobs/PushProcessMessageJob.java
@@ -142,6 +142,8 @@ public final class PushProcessMessageJob extends BaseJob {
         } catch (BadGroupIdException e) {
           Log.w(TAG, "Bad groupId! Using default queue. ID: " + content.getTimestamp());
         }
+      } else if (content.getSyncMessage().isPresent() && content.getSyncMessage().get().getSent().isPresent() && content.getSyncMessage().get().getSent().get().getDestination().isPresent()) {
+        queueName = getQueueName(RecipientId.fromHighTrust(content.getSyncMessage().get().getSent().get().getDestination().get()));
       } else {
         queueName = getQueueName(RecipientId.fromHighTrust(content.getSender()));
       }