summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/main/java/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutor.java5
-rw-r--r--src/test/groovy/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutorIntegrationSpec.groovy2
2 files changed, 3 insertions, 4 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;
diff --git a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutorIntegrationSpec.groovy b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutorIntegrationSpec.groovy
index 54c0fe09..b377a37b 100644
--- a/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutorIntegrationSpec.groovy
+++ b/src/test/groovy/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutorIntegrationSpec.groovy
@@ -117,7 +117,7 @@ class AsyncTaskExecutorIntegrationSpec extends Specification {
def 'Publish and Subscribe message - failure'() {
when: 'a failure event is published'
def exception = new HttpClientRequestException('some cm handle', 'Node not found', HttpStatus.INTERNAL_SERVER_ERROR)
- objectUnderTest.publishAsyncFailureEvent(TEST_TOPIC, '67890', DataAccessRequest.OperationEnum.READ, exception)
+ objectUnderTest.publishAsyncFailureEvent(TEST_TOPIC, '67890', exception)
and: 'the topic is polled'
def records = consumer.poll(Duration.ofMillis(1500))
then: 'the record received is the event sent'