diff options
| author |   wasala <przemyslaw.wasala@nokia.com> | 2018-06-27 14:29:06 +0200 |
|---|---|---|
| committer | wasala <przemyslaw.wasala@nokia.com> | 2018-08-07 09:18:01 +0200 |
| commit | 79984d737c71d3c92f3cd283eaf2b9b6157c2ce2 (patch) | |
| tree | d467284687fa9db1ee15ead8a2f94594ec609a05 /prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapConsumerTask.java | |
| parent | c8c9a242f7a1f8454e2cf94b0442128533569dc5 (diff) | |
Refactor Optional in MonoResponse
Added JUnit tests for DmaapConsumer
Reactive Client.
Added property for spring to run
PRH as none-web application
Change-Id: I8b762389927151387da5b79e8b75b670600ee5e8
Issue-ID: DCAEGEN2-563
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.java | 4 |
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 753d1f9c..5cd30f8b 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 @@ -30,11 +30,11 @@ import reactor.core.publisher.Mono; */ abstract class DmaapConsumerTask { - abstract Mono<Optional<ConsumerDmaapModel>> consume(Mono<Optional<String>> message) throws PrhTaskException; + abstract Mono<ConsumerDmaapModel> consume(Mono<String> message) throws PrhTaskException; abstract DmaapConsumerReactiveHttpClient resolveClient(); abstract void initConfigs(); - protected abstract Mono<Optional<ConsumerDmaapModel>> execute(String object) throws PrhTaskException; + protected abstract Mono<ConsumerDmaapModel> execute(String object) throws PrhTaskException; } |