summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/cps/ncmp/dmi/service/NcmpKafkaPublisherService.java
diff options
context:
space:
mode:
authorJosephKeenan <joseph.keenan@est.tech>2022-05-23 15:43:05 +0100
committerJosephKeenan <joseph.keenan@est.tech>2022-06-01 16:56:50 +0100
commit2cd8b98223bd49975fcca0ec7f1d4673a4163074 (patch)
treed26e809ad7befaf8b7815271a6fcc501f67b3117 /src/main/java/org/onap/cps/ncmp/dmi/service/NcmpKafkaPublisherService.java
parentdf26bc38a75f10650ce5785cdc9bd7b9516f6f25 (diff)
Async request response dmi -> NCMP
-Added Async for passthrough running and operational -Build will fail until cps is merged https://gerrit.onap.org/r/c/cps/+/128685 Issue-ID: CPS-830 Change-Id: Iedbfab109f5cd777a5be8eed7414758d0f5ec05c Signed-off-by: JosephKeenan <joseph.keenan@est.tech> Signed-off-by: ToineSiebelink <toine.siebelink@est.tech> Signed-off-by: JosephKeenan <joseph.keenan@est.tech>
Diffstat (limited to 'src/main/java/org/onap/cps/ncmp/dmi/service/NcmpKafkaPublisherService.java')
-rw-r--r--src/main/java/org/onap/cps/ncmp/dmi/service/NcmpKafkaPublisherService.java44
1 files changed, 0 insertions, 44 deletions
diff --git a/src/main/java/org/onap/cps/ncmp/dmi/service/NcmpKafkaPublisherService.java b/src/main/java/org/onap/cps/ncmp/dmi/service/NcmpKafkaPublisherService.java
deleted file mode 100644
index f5e1839b..00000000
--- a/src/main/java/org/onap/cps/ncmp/dmi/service/NcmpKafkaPublisherService.java
+++ /dev/null
@@ -1,44 +0,0 @@
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2022 Nordix Foundation
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- * SPDX-License-Identifier: Apache-2.0
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.cps.ncmp.dmi.service;
-
-import lombok.AllArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-@Slf4j
-@Service
-@AllArgsConstructor
-public class NcmpKafkaPublisherService {
-
- private final NcmpKafkaPublisher ncmpKafkaPublisher;
-
- /**
- * publish the message to NCMP.
- *
- * @param messageKey message key
- * @param message message payload
- */
- public void publishToNcmp(final String messageKey, final Object message) {
- log.debug("Publishing message : {} to NCMP with message-key : {}", message, messageKey);
- ncmpKafkaPublisher.sendMessage(messageKey, message);
- }
-}