X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=sdnr%2Fwt%2Fdevicemanager%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fccsdk%2Ffeatures%2Fsdnr%2Fwt%2Fdevicemanager%2Fdcaeconnector%2Fimpl%2FDcaeForwarderImpl.java;fp=sdnr%2Fwt%2Fdevicemanager%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fccsdk%2Ffeatures%2Fsdnr%2Fwt%2Fdevicemanager%2Fdcaeconnector%2Fimpl%2FDcaeForwarderImpl.java;h=0000000000000000000000000000000000000000;hb=d1981f7e68272cdc5618139a363b80806c2aa77c;hp=88854dbd11e881872fec6bb801061d0ce84a6ab9;hpb=032ce4ec7c3d7ac138555dfe980ca53ebbf39f01;p=ccsdk%2Ffeatures.git diff --git a/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/dcaeconnector/impl/DcaeForwarderImpl.java b/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/dcaeconnector/impl/DcaeForwarderImpl.java deleted file mode 100644 index 88854dbd1..000000000 --- a/sdnr/wt/devicemanager/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/dcaeconnector/impl/DcaeForwarderImpl.java +++ /dev/null @@ -1,81 +0,0 @@ -/******************************************************************************* - * ============LICENSE_START======================================================================== - * ONAP : ccsdk feature sdnr wt - * ================================================================================================= - * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved. - * ================================================================================================= - * 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. - * ============LICENSE_END========================================================================== - ******************************************************************************/ - -package org.onap.ccsdk.features.sdnr.wt.devicemanager.dcaeconnector.impl; - -import org.eclipse.jdt.annotation.NonNull; -import org.eclipse.jdt.annotation.Nullable; -import org.onap.ccsdk.features.sdnr.wt.common.HtAssert; -import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.ProviderClient; -import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.handler.NetconfEventListenerHandler12; -import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.ProblemNotificationXml; -import org.onap.ccsdk.features.sdnr.wt.devicemanager.maintenance.MaintenanceService; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class DcaeForwarderImpl implements DcaeForwarderInternal, AutoCloseable { - - private static final Logger LOG = LoggerFactory.getLogger(NetconfEventListenerHandler12.class); - - private final @Nullable ProviderClient aotsmClient; - private final ProviderClient dcaeProvider; - private final MaintenanceService maintenanceService; - - public DcaeForwarderImpl(@Nullable ProviderClient aotsmClient, @Nullable ProviderClient dcaeProvider, - @NonNull MaintenanceService maintenanceService) { - super(); - - HtAssert.nonnull(maintenanceService); - this.aotsmClient = aotsmClient; - this.dcaeProvider = dcaeProvider; - this.maintenanceService = maintenanceService; - } - - @Override - @SuppressWarnings("null") - public void sendProblemNotificationUsingMaintenanceFilter(String nodeId, ProblemNotificationXml notificationXml) { - if (!this.maintenanceService.isONFObjectInMaintenance(nodeId, notificationXml.getObjectId(), - notificationXml.getProblem())) { - if (dcaeProvider != null) { - this.dcaeProvider.sendProblemNotification(nodeId, notificationXml); - } - if (this.aotsmClient != null) { - this.aotsmClient.sendProblemNotification(nodeId, notificationXml); - } - } else { - LOG.debug("Notification will not be sent to external services. Device " + nodeId - + " is in maintenance mode"); - } - } - - @Override - public void sendProblemNotification(String nodeId, ProblemNotificationXml notificationXml) { - //to prevent push alarms on reconnect - //=> only pushed alarms are forwared to dcae - //dcaeProvider.sendProblemNotification(nodeName, notificationXml); - if(aotsmClient!=null) { - aotsmClient.sendProblemNotification(nodeId, notificationXml); - } - - } - - @Override - public void close() throws Exception { - } - -}