diff options
Diffstat (limited to 'src/main/java/org/onap')
| -rw-r--r-- | src/main/java/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutor.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/main/java/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutor.java b/src/main/java/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutor.java index 7189f6c9..6a1c6d1d 100644 --- a/src/main/java/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutor.java +++ b/src/main/java/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutor.java @@ -78,7 +78,7 @@ public class AsyncTaskExecutor { publishAsyncEvent(topicName, requestId, resourceDataAsJson, status, code); } else { log.error("Error occurred with async request {}", throwable.getMessage()); - publishAsyncFailureEvent(topicName, requestId, operation, throwable); + publishAsyncFailureEvent(topicName, requestId, throwable); } }); log.info("Async task completed."); @@ -95,9 +95,8 @@ public class AsyncTaskExecutor { dmiAsyncRequestResponseEventProducer.sendMessage(requestId, cpsAsyncRequestResponseEvent); } - protected void publishAsyncFailureEvent(final String topicName, + private void publishAsyncFailureEvent(final String topicName, final String requestId, - final DataAccessRequest.OperationEnum operation, final Throwable throwable) { HttpStatus httpStatus = HttpStatus.INTERNAL_SERVER_ERROR; |