- private String buildDmaapResponse(String correlationId, String originatorId, String requestId, String status,
- String message) {
- System.out.println("buildResponse ");
- return new JSONObject().put("type", "response").put(correlationId, correlationId).put("timestamp", "")
- .put("originatorId", originatorId).put("requestId", requestId).put("status", status)
- .put("message", message).toString();
+ private Optional<String> getDmaapResponseMessage(DmaapRequestMessage dmaapRequestMessage,
+ ResponseEntity<?> policySchemas) {
+ DmaapResponseMessage dmaapResponseMessage = DmaapResponseMessage.builder()
+ .status(policySchemas.getStatusCode().toString()).message(policySchemas.getBody().toString())
+ .type("response").correlationId(dmaapRequestMessage.getCorrelationId())
+ .originatorId(dmaapRequestMessage.getOriginatorId()).requestId(dmaapRequestMessage.getRequestId())
+ .build();
+ try {
+ return Optional.of(mapper.writeValueAsString(dmaapResponseMessage));
+ } catch (JsonProcessingException e) {
+ logger.error("Exception occured during getDmaapResponseMessage", e);
+ }
+ return Optional.empty();