diff options
author | Piotr Jaszczyk <piotr.jaszczyk@nokia.com> | 2019-05-22 14:56:15 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2019-05-22 14:56:15 +0000 |
commit | e2f12ecdee8f9320e23b95a1671cb7c8fcacf361 (patch) | |
tree | abc1d6e5a2e0f157bb84777aa4685d346e2c9874 /prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java | |
parent | 41216decc9e167ee85aff6391f67dcf4b94f489c (diff) | |
parent | 97b4eac83d68e1b44b9ce628bcc9440d5f3353ef (diff) |
Merge "Remove deprecated method from PRH"
Diffstat (limited to 'prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java')
-rw-r--r-- | prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java index 4bb5a31c..e0dcf0b3 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java @@ -52,13 +52,13 @@ public class AaiProducerTaskImpl extends AaiProducerTask { @Override Mono<ConsumerDmaapModel> publish(ConsumerDmaapModel consumerDmaapModel) { - Mono<HttpResponse> resposne = aaiHttpPatchClient.getAaiResponse(consumerDmaapModel); - return resposne.flatMap(response -> { - if (HttpUtils.isSuccessfulResponseCode(response.statusCode())) { + Mono<HttpResponse> response = aaiHttpPatchClient.getAaiResponse(consumerDmaapModel); + return response.flatMap(r -> { + if (HttpUtils.isSuccessfulResponseCode(r.statusCode())) { return Mono.just(consumerDmaapModel); } return Mono - .error(new AaiNotFoundException("Incorrect response code for continuation of tasks workflow" + response.statusCode())); + .error(new AaiNotFoundException("Incorrect response code for continuation of tasks workflow" + r.statusCode())); }); } |