try3

Author: Anover000

src/main/java/org/mifos/processor/bulk/camel/routes/SplittingRoute.java

@@ -86,6 +86,8 @@ public void configure() throws Exception {
                 for (String payeeId : distinctPayeeIds) {
                     List<Transaction> transactionsForPayee = transactionList.stream()
                             .filter(transaction -> payeeId.equals(transaction.getPayeeDfspId())).collect(Collectors.toList());
+                    logger.info(objectMapper.writeValueAsString(transactionsForPayee));
+                    logger.info(objectMapper.writeValueAsString(distinctPayeeIds) +" - "+ payeeId);
                     transactionsByPayeeId.put(payeeId, transactionsForPayee);
                     String subBatchId = UUID.randomUUID().toString();
                     subBatchIdList.add(subBatchId);
@@ -112,8 +114,11 @@ public void configure() throws Exception {
                     CsvSchema csvSchema = csvMapper.schemaFor(Transaction.class);
                     csvSchema = csvSchema.withHeader();
                     File file = new File(filename);
+                    logger.info(objectMapper.writeValueAsString(transactionsForSpecificPayee));
+                    logger.info(payeeId);
                     SequenceWriter writer = csvMapper.writerWithSchemaFor(Transaction.class).with(csvSchema).writeValues(file);
                     for (Transaction transaction : transactionsForSpecificPayee) {
+                        logger.info("trans-action {} {}", objectMapper.writeValueAsString(transaction), payeeId);
                         transaction.setBatchId(subBatchIdPayeeMap.get(payeeId));
                         writer.write(transaction);
                     }