diff --git a/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java b/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java index 2359ab5..3fa2535 100644 --- a/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java +++ b/src/main/java/com/uci/outbound/consumers/NotificationConsumerReactive.java @@ -24,7 +24,6 @@ import java.io.ByteArrayInputStream; import java.time.Duration; -import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.function.Consumer; @@ -98,7 +97,6 @@ public Flux sendOutboundMessage(List> m log.error("NotificationConsumerReactive:Exception: Exception in processOutBoundMessageF:" + e.getMessage()); return Flux.empty(); }); -// return Flux.fromIterable(new ArrayList<>()); } catch (Exception e) { HashMap attachments = new HashMap<>(); attachments.put("Exception", ExceptionUtils.getStackTrace(e)); @@ -106,7 +104,6 @@ public Flux sendOutboundMessage(List> m sentEmail(null, "PFA", null, attachments); log.error("NotificationConsumerReactive:Exception: " + e.getMessage()); return Flux.empty(); -// return Flux.fromIterable(new ArrayList<>()); } }); }