diff options
Diffstat (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/Task.java')
-rw-r--r-- | prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/Task.java | 20 |
1 files changed, 7 insertions, 13 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/Task.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/Task.java index 8aa01446..e2b11fdc 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/Task.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/Task.java @@ -28,21 +28,15 @@ import org.onap.dcaegen2.services.prh.exceptions.PrhTaskException; public abstract class Task<R, S, C> { - private Task taskProcess; + Task taskProcess; - public void setNext(Task task) { - this.taskProcess = task; - } - - public void receiveRequest(R body) throws PrhTaskException { + abstract protected void receiveRequest(R body) throws PrhTaskException; - S response = execute(body); - if (taskProcess != null) { - taskProcess.receiveRequest(response); - } - } + abstract protected S execute(R object) throws PrhTaskException; - abstract S execute(R object) throws PrhTaskException; + abstract protected C resolveConfiguration(); - abstract C resolveConfiguration(); + void setNext(Task task) { + this.taskProcess = task; + } } |