Use proper processing queue for sync messages.

This commit is contained in:
Greyson Parrelli
2021-12-21 15:07:13 -05:00
parent bdd48629c6
commit 5102f5215c

View File

@@ -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()));
}