diff options
Diffstat (limited to 'bpmn/mso-infrastructure-bpmn/src/main/java/org/onap/so/bpmn/common/workflow/service/WorkflowMessageResource.java')
-rw-r--r-- | bpmn/mso-infrastructure-bpmn/src/main/java/org/onap/so/bpmn/common/workflow/service/WorkflowMessageResource.java | 113 |
1 files changed, 51 insertions, 62 deletions
diff --git a/bpmn/mso-infrastructure-bpmn/src/main/java/org/onap/so/bpmn/common/workflow/service/WorkflowMessageResource.java b/bpmn/mso-infrastructure-bpmn/src/main/java/org/onap/so/bpmn/common/workflow/service/WorkflowMessageResource.java index 075102331c..1e9ebdf0b2 100644 --- a/bpmn/mso-infrastructure-bpmn/src/main/java/org/onap/so/bpmn/common/workflow/service/WorkflowMessageResource.java +++ b/bpmn/mso-infrastructure-bpmn/src/main/java/org/onap/so/bpmn/common/workflow/service/WorkflowMessageResource.java @@ -24,7 +24,6 @@ package org.onap.so.bpmn.common.workflow.service; import java.util.HashMap; import java.util.Map; - import javax.ws.rs.Consumes; import javax.ws.rs.HeaderParam; import javax.ws.rs.POST; @@ -33,7 +32,6 @@ import javax.ws.rs.PathParam; import javax.ws.rs.Produces; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; - import org.onap.so.bpmn.common.workflow.service.CallbackHandlerService.CallbackError; import org.onap.so.bpmn.common.workflow.service.CallbackHandlerService.CallbackResult; import org.onap.so.logger.ErrorCode; @@ -42,13 +40,12 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; - import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; /** - * Generalized REST interface that injects a message event into a waiting BPMN process. - * Examples: + * Generalized REST interface that injects a message event into a waiting BPMN process. Examples: + * * <pre> * /WorkflowMessage/SDNCAResponse/6d10d075-100c-42d0-9d84-a52432681cae-1478486185286 * /WorkflowMessage/SDNCAEvent/USOSTCDALTX0101UJZZ01 @@ -57,70 +54,62 @@ import io.swagger.annotations.ApiOperation; @Path("/") @Api(description = "Provides a generic service to inject messages into a waiting BPMN Proccess") @Component -public class WorkflowMessageResource{ - private static final Logger logger = LoggerFactory.getLogger(WorkflowMessageResource.class); - private static final String LOGMARKER = "[WORKFLOW-MESSAGE]"; - - @Autowired - CallbackHandlerService callback; - - @POST - @Path("/WorkflowMessage/{messageType}/{correlator}") - @ApiOperation( - value = "Workflow message correlator", - notes = "" - ) - @Consumes("*/*") - @Produces(MediaType.TEXT_PLAIN) - public Response deliver( - @HeaderParam("Content-Type") String contentType, - @PathParam("messageType") String messageType, - @PathParam("correlator") String correlator, - String message) { +public class WorkflowMessageResource { + private static final Logger logger = LoggerFactory.getLogger(WorkflowMessageResource.class); + private static final String LOGMARKER = "[WORKFLOW-MESSAGE]"; + + @Autowired + CallbackHandlerService callback; + + @POST + @Path("/WorkflowMessage/{messageType}/{correlator}") + @ApiOperation(value = "Workflow message correlator", notes = "") + @Consumes("*/*") + @Produces(MediaType.TEXT_PLAIN) + public Response deliver(@HeaderParam("Content-Type") String contentType, + @PathParam("messageType") String messageType, @PathParam("correlator") String correlator, String message) { - String method = "receiveWorkflowMessage"; + String method = "receiveWorkflowMessage"; - logger.debug(LOGMARKER + " Received workflow message" - + " type='" + messageType + "'" - + " correlator='" + correlator + "'" - + (contentType == null ? "" : " contentType='" + contentType + "'") - + " message=" + System.lineSeparator() + message); + logger.debug(LOGMARKER + " Received workflow message" + " type='" + messageType + "'" + " correlator='" + + correlator + "'" + (contentType == null ? "" : " contentType='" + contentType + "'") + " message=" + + System.lineSeparator() + message); - if (messageType == null || messageType.isEmpty()) { - String msg = "Missing message type"; - logger.debug(LOGMARKER + " " + msg); - logger.error("{} {} {} {}", MessageEnum.BPMN_GENERAL_EXCEPTION.toString(), "BPMN", - ErrorCode.DataError.getValue(), LOGMARKER + ":" + msg); - return Response.status(400).entity(msg).build(); - } + if (messageType == null || messageType.isEmpty()) { + String msg = "Missing message type"; + logger.debug(LOGMARKER + " " + msg); + logger.error("{} {} {} {}", MessageEnum.BPMN_GENERAL_EXCEPTION.toString(), "BPMN", + ErrorCode.DataError.getValue(), LOGMARKER + ":" + msg); + return Response.status(400).entity(msg).build(); + } - if (correlator == null || correlator.isEmpty()) { - String msg = "Missing correlator"; - logger.debug(LOGMARKER + " " + msg); - logger.error("{} {} {} {}", MessageEnum.BPMN_GENERAL_EXCEPTION.toString(), "BPMN", - ErrorCode.DataError.getValue(), LOGMARKER + ":" + msg); - return Response.status(400).entity(msg).build(); - } + if (correlator == null || correlator.isEmpty()) { + String msg = "Missing correlator"; + logger.debug(LOGMARKER + " " + msg); + logger.error("{} {} {} {}", MessageEnum.BPMN_GENERAL_EXCEPTION.toString(), "BPMN", + ErrorCode.DataError.getValue(), LOGMARKER + ":" + msg); + return Response.status(400).entity(msg).build(); + } - String messageEventName = "WorkflowMessage"; - String messageVariable = messageType + "_MESSAGE"; - String correlationVariable = messageType + "_CORRELATOR"; - String correlationValue = correlator; - String contentTypeVariable = messageType + "_CONTENT_TYPE"; + String messageEventName = "WorkflowMessage"; + String messageVariable = messageType + "_MESSAGE"; + String correlationVariable = messageType + "_CORRELATOR"; + String correlationValue = correlator; + String contentTypeVariable = messageType + "_CONTENT_TYPE"; - Map<String, Object> variables = new HashMap<>(); + Map<String, Object> variables = new HashMap<>(); - if (contentType != null) { - variables.put(contentTypeVariable, contentType); - } + if (contentType != null) { + variables.put(contentTypeVariable, contentType); + } - CallbackResult result = callback.handleCallback(method, message, messageEventName, - messageVariable, correlationVariable, correlationValue, LOGMARKER, variables); + CallbackResult result = callback.handleCallback(method, message, messageEventName, messageVariable, + correlationVariable, correlationValue, LOGMARKER, variables); - if (result instanceof CallbackError) { - return Response.status(500).entity(((CallbackError)result).getErrorMessage()).build(); - } else { - return Response.status(204).build(); - } - } + if (result instanceof CallbackError) { + return Response.status(500).entity(((CallbackError) result).getErrorMessage()).build(); + } else { + return Response.status(204).build(); + } + } } |