diff options
| -rw-r--r-- | src/main/java/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutor.java | 5 | ||||
| -rw-r--r-- | src/test/groovy/org/onap/cps/ncmp/dmi/notifications/async/AsyncTaskExecutorIntegrationSpec.groovy | 2 |
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' |