aboutsummaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java
diff options
context:
space:
mode:
authorwasala <przemyslaw.wasala@nokia.com>2018-06-25 12:29:39 +0200
committerwasala <przemyslaw.wasala@nokia.com>2018-08-06 14:22:18 +0200
commit58cbfef5661242a2523b7a183a664498fd1f405a (patch)
tree68fd4d654d43124e8450526fa4a54c6e4a345322 /prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java
parent2cfcc6756e59ed8cda571efa8b29764eab7837c8 (diff)
Cleaned in code in reactive tasks
*Formated code *Added handling exceptions *Deleted unused code Change-Id: I3e95bcb8ba7cdf85f6a1daaec7cadc86080e0b10 Issue-ID: DCAEGEN2-557 Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
Diffstat (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java')
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java
index 56b678a3..1be3b28d 100644
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java
@@ -26,7 +26,7 @@ import org.onap.dcaegen2.services.prh.service.consumer.ExtendedDmaapConsumerHttp
/**
* @author <a href="mailto:przemyslaw.wasala@nokia.com">Przemysław Wąsala</a> on 4/13/18
*/
-abstract class DmaapConsumerTask /*<R, S, C> extends Task<R, S, C>*/ {
+abstract class DmaapConsumerTask {
abstract ConsumerDmaapModel consume(String message) throws PrhTaskException;
@@ -34,5 +34,5 @@ abstract class DmaapConsumerTask /*<R, S, C> extends Task<R, S, C>*/ {
abstract void initConfigs();
- abstract protected ConsumerDmaapModel execute(String object) throws PrhTaskException;
+ protected abstract ConsumerDmaapModel execute(String object) throws PrhTaskException;
}