[PHEE-522] Create Sync callback functionality in bulk (#137)

* callback if check

* readable logs

Author: logoutdhaval

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

@@ -44,10 +44,11 @@ public void configure() throws Exception {
                     ObjectMapper objectMapper = new ObjectMapper();
                     String jsonString = objectMapper.writeValueAsString(body);
                     exchange.getIn().setBody(jsonString);
-                }).setHeader(Exchange.HTTP_METHOD, constant("POST"))
+                }).choice().when(exchangeProperty("X-CallbackURL").isNotNull()).setHeader(Exchange.HTTP_METHOD, constant("POST"))
                 .toD("${exchangeProperty.X-CallbackURL}?bridgeEndpoint=true&throwExceptionOnFailure=false")
-                .log(LoggingLevel.INFO, "Callback Response body: ${body}").choice()
-                .when(header(Exchange.HTTP_RESPONSE_CODE).regex("^2\\d{2}$")).log(LoggingLevel.INFO, "Callback sending was successful")
+                .log(LoggingLevel.INFO, "Callback Response body: ${body}").endChoice().otherwise()
+                .log("Unable to send callback: callback url is null").choice().when(header(Exchange.HTTP_RESPONSE_CODE).regex("^2\\d{2}$"))
+                .when(exchangeProperty("X-CallbackURL").isNotNull()).log(LoggingLevel.INFO, "Callback sending was successful")
                 .process(exchange -> {
                     List phases = exchange.getProperty(PHASES, List.class);
                     exchange.setProperty(CALLBACK_RESPONSE_CODE, exchange.getIn().getHeader(Exchange.HTTP_RESPONSE_CODE));

src/main/java/org/mifos/processor/bulk/zeebe/worker/BatchAccountLookupWorker.java

@@ -52,7 +52,7 @@ public void setup() {
             String registeringInstituteId = variables.get(REGISTERING_INSTITUTE_ID).toString();
             logger.info("registeringInstituteId in worker {}", registeringInstituteId);
             variables.put(CACHED_TRANSACTION_ID, job.getKey());
-            exchange.setProperty(HEADER_REGISTERING_INSTITUTE_ID, registeringInstituteId) ;
+            exchange.setProperty(HEADER_REGISTERING_INSTITUTE_ID, registeringInstituteId);
             exchange.setProperty(SERVER_FILE_NAME, filename);
             exchange.setProperty(REQUEST_ID, job.getKey());
             exchange.setProperty(CALLBACK, identityMapperURL + batchAccountLookupCallback);