summaryrefslogtreecommitdiffstats
path: root/appc-dispatcher/appc-command-executor/appc-command-executor-core/src/main/java/org/openecomp/appc/executor/impl/CommandTask.java
diff options
context:
space:
mode:
Diffstat (limited to 'appc-dispatcher/appc-command-executor/appc-command-executor-core/src/main/java/org/openecomp/appc/executor/impl/CommandTask.java')
-rw-r--r--appc-dispatcher/appc-command-executor/appc-command-executor-core/src/main/java/org/openecomp/appc/executor/impl/CommandTask.java44
1 files changed, 15 insertions, 29 deletions
diff --git a/appc-dispatcher/appc-command-executor/appc-command-executor-core/src/main/java/org/openecomp/appc/executor/impl/CommandTask.java b/appc-dispatcher/appc-command-executor/appc-command-executor-core/src/main/java/org/openecomp/appc/executor/impl/CommandTask.java
index f34746b24..21a00861e 100644
--- a/appc-dispatcher/appc-command-executor/appc-command-executor-core/src/main/java/org/openecomp/appc/executor/impl/CommandTask.java
+++ b/appc-dispatcher/appc-command-executor/appc-command-executor-core/src/main/java/org/openecomp/appc/executor/impl/CommandTask.java
@@ -51,44 +51,30 @@ import org.slf4j.MDC;
public abstract class CommandTask implements Runnable {
- protected RequestHandler requestHandler;
- protected WorkFlowManager workflowManager;
+ protected final RequestHandler requestHandler;
+ protected final WorkFlowManager workflowManager;
+ protected final RuntimeContext commandRequest;
- private RuntimeContext commandRequest;
-
- public RuntimeContext getCommandRequest() {
- return commandRequest;
- }
-
- public void setCommandRequest(RuntimeContext commandRequest) {
+ protected CommandTask(RuntimeContext commandRequest, RequestHandler requestHandler,
+ WorkFlowManager workflowManager) {
+ super();
this.commandRequest = commandRequest;
- }
-
- private static final EELFLogger logger = EELFManager.getInstance().getLogger(CommandTask.class);
-
- public void setWorkflowManager(WorkFlowManager workflowManager) {
- this.workflowManager = workflowManager;
- }
-
- public void setRequestHandler(RequestHandler requestHandler) {
this.requestHandler = requestHandler;
+ this.workflowManager = workflowManager;
}
- CommandTask(){
- }
+ private static final EELFLogger logger = EELFManager.getInstance().getLogger(CommandTask.class);
- public void onRequestCompletion(RuntimeContext request, CommandResponse response , boolean isAAIUpdated) {
+ public void onRequestCompletion(CommandResponse response, boolean isAAIUpdated) {
logger.debug("Entry: onRequestCompletion()");
- requestHandler.onRequestExecutionEnd(request, isAAIUpdated);
+ requestHandler.onRequestExecutionEnd(commandRequest, isAAIUpdated);
}
- public abstract void onRequestCompletion(RuntimeContext request, CommandResponse response);
+ public abstract void onRequestCompletion(CommandResponse response);
- protected CommandResponse buildCommandResponse(RuntimeContext request, WorkflowResponse response) {
+ protected CommandResponse buildCommandResponse(WorkflowResponse response) {
- CommandResponse commandResponse = new CommandResponse();
- commandResponse.setRuntimeContext(request);
- return commandResponse;
+ return new CommandResponse(commandRequest);
}
@@ -114,8 +100,8 @@ public abstract class CommandTask implements Runnable {
WorkflowResponse response = workflowManager.executeWorkflow(workflowRequest);
- CommandResponse commandResponse = buildCommandResponse(commandRequest, response);
- this.onRequestCompletion(commandRequest,commandResponse);
+ CommandResponse commandResponse = buildCommandResponse(response);
+ this.onRequestCompletion(commandResponse);
}
}