Skip to content

Commit

Permalink
Merge pull request #46 from samagra-comms/development
Browse files Browse the repository at this point in the history
Unused code removed
  • Loading branch information
pankajjangid05 authored Jun 16, 2023
2 parents 4ad3319 + c97a7f5 commit b0c4adc
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -98,15 +97,13 @@ public Flux<XMessage> sendOutboundMessage(List<ReceiverRecord<String, String>> m
log.error("NotificationConsumerReactive:Exception: Exception in processOutBoundMessageF:" + e.getMessage());
return Flux.empty();
});
// return Flux.fromIterable(new ArrayList<>());
} catch (Exception e) {
HashMap<String, String> attachments = new HashMap<>();
attachments.put("Exception", ExceptionUtils.getStackTrace(e));
attachments.put("XMessage", "No xmessage");
sentEmail(null, "PFA", null, attachments);
log.error("NotificationConsumerReactive:Exception: " + e.getMessage());
return Flux.empty();
// return Flux.fromIterable(new ArrayList<>());
}
});
}
Expand Down

0 comments on commit b0c4adc

Please sign in to comment.