Added simply logs from tasks.

*Logging responsed object from DmaaP
*Logging parsed oject from DmaaP
*Logging sended object to AAI
*Logging sended object and topic To DmaaP

Change-Id: I33de0cd751762ac004f9d8a09beee921f4026af6
Issue-ID: DCAEGEN2-545
Signed-off-by: wasala <przemyslaw.wasala@nokia.com>

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;
+    }
 }