diff --git a/libsignal/service/src/main/java/org/whispersystems/signalservice/api/SignalServiceMessageSender.java b/libsignal/service/src/main/java/org/whispersystems/signalservice/api/SignalServiceMessageSender.java index f9f9c2976..3fb510cdd 100644 --- a/libsignal/service/src/main/java/org/whispersystems/signalservice/api/SignalServiceMessageSender.java +++ b/libsignal/service/src/main/java/org/whispersystems/signalservice/api/SignalServiceMessageSender.java @@ -1820,6 +1820,10 @@ public class SignalServiceMessageSender { Set destinations = store.getAllAddressesWithActiveSessions(addressNames); Map> devicesByAddressName = new HashMap<>(); + destinations.addAll(recipients.stream() + .map(a -> new SignalProtocolAddress(a.getIdentifier(), SignalServiceAddress.DEFAULT_DEVICE_ID)) + .collect(Collectors.toList())); + for (SignalProtocolAddress destination : destinations) { List devices = devicesByAddressName.containsKey(destination.getName()) ? devicesByAddressName.get(destination.getName()) : new LinkedList<>(); devices.add(destination.getDeviceId());