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;