[Hot Fix] - Sending Notifications in Chunks

samagra-comms · Apr 17, 2023 · f114c27 · f114c27
1 parent d7c778d
commit f114c27
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/main/java/com/uci/orchestrator/Consumer/ReactiveConsumer.java b/src/main/java/com/uci/orchestrator/Consumer/ReactiveConsumer.java
@@ -22,7 +22,10 @@
 import io.fusionauth.domain.UserRegistration;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import messagerosa.core.model.*;
+import messagerosa.core.model.DeviceType;
+import messagerosa.core.model.SenderReceiverInfo;
+import messagerosa.core.model.Transformer;
+import messagerosa.core.model.XMessage;
 import messagerosa.xml.XMessageParser;
 import org.apache.commons.lang3.tuple.Pair;
 import org.json.JSONArray;
@@ -40,7 +43,11 @@
 import javax.xml.bind.JAXBException;
 import java.io.ByteArrayInputStream;
 import java.time.LocalDateTime;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.UUID;
+import java.util.Comparator;
 import java.util.function.Consumer;
 import java.util.function.Function;