diff options
| author |   raviteja.karumuri <raviteja.karumuri@est.tech> | 2023-06-02 10:45:13 +0100 |
|---|---|---|
| committer | raviteja.karumuri <raviteja.karumuri@est.tech> | 2023-06-06 14:01:08 +0100 |
| commit | 9438a53cf6e15b0d49fa40cb85dc978dc9fb7f19 (patch) | |
| tree | 722b76246ca5e3a3d9432a3edccf13817ef3458e /cps-ncmp-service/src/test/groovy | |
| parent | ec3a1d19456b034593b2a365c044a3904c32e98d (diff) | |
NCMP : forward bulk response messages to client topic
# Fixing the avc subscription event is not consuming even there is a record published on to the topic.
Issue-ID: CPS-1557
Signed-off-by: raviteja.karumuri <raviteja.karumuri@est.tech>
Change-Id: If09fd1849f467785141cc56639839ddda9f2c0de
Diffstat (limited to 'cps-ncmp-service/src/test/groovy')
| -rw-r--r-- | cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncBatchEventConsumerSpec.groovy | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncBatchEventConsumerSpec.groovy b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncBatchEventConsumerSpec.groovy index 65c43a011d..28464bb91c 100644 --- a/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncBatchEventConsumerSpec.groovy +++ b/cps-ncmp-service/src/test/groovy/org/onap/cps/ncmp/api/impl/async/NcmpAsyncBatchEventConsumerSpec.groovy @@ -55,7 +55,7 @@ class NcmpAsyncBatchEventConsumerSpec extends MessagingBaseSpec { JsonObjectMapper jsonObjectMapper @Autowired - RecordFilterStrategy<Object, Object> recordFilterStrategy + RecordFilterStrategy<String, BatchDataResponseEventV1> recordFilterStrategy def kafkaConsumer = new KafkaConsumer<>(consumerConfigProperties('test')) def static clientTopic = 'client-topic' |