1 files changed, 0 insertions, 156 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/PublishNotificationRunnable.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/PublishNotificationRunnable.java
deleted file mode 100644
index c283ecc92b..0000000000
--- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/PublishNotificationRunnable.java
+++ /dev/null
@@ -1,156 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * SDC
- * ================================================================================
- * Copyright (C) 2017 AT&T 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.openecomp.sdc.be.components.distribution.engine;
-
-import org.openecomp.sdc.be.config.DistributionEngineConfiguration;
-import org.openecomp.sdc.be.distribution.api.client.CambriaOperationStatus;
-import org.openecomp.sdc.be.impl.ComponentsUtils;
-import org.openecomp.sdc.be.model.Service;
-import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
-import org.openecomp.sdc.common.util.ThreadLocalsHolder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class PublishNotificationRunnable implements Runnable {
-
-	private String envName;
-	private String distributionId;
-	private Service service;
-	private INotificationData data;
-	private DistributionEngineConfiguration deConfiguration;
-	private String topicName;
-	private CambriaHandler cambriaHandler;
-	private ComponentsUtils componentUtils;
-	private String userId;
-	private String modifierName;
-	private String requestId;
-
-	private static Logger logger = LoggerFactory.getLogger(PublishNotificationRunnable.class.getName());
-
-	public PublishNotificationRunnable(String envName, String distributionId, Service service, INotificationData data, DistributionEngineConfiguration deConfiguration, String topicName, String userId, String modifierName,
-			CambriaHandler cambriaHandler, ComponentsUtils componentUtils, String requestId) {
-		super();
-		this.envName = envName;
-		this.distributionId = distributionId;
-		this.service = service;
-		this.data = data;
-		this.deConfiguration = deConfiguration;
-		this.topicName = topicName;
-		this.cambriaHandler = cambriaHandler;
-		this.componentUtils = componentUtils;
-		this.userId = userId;
-		this.modifierName = modifierName;
-		this.requestId = requestId;
-	}
-
-	public INotificationData getData() {
-		return data;
-	}
-
-	public void setData(INotificationData data) {
-		this.data = data;
-	}
-
-	public DistributionEngineConfiguration getDeConfiguration() {
-		return deConfiguration;
-	}
-
-	public void setDeConfiguration(DistributionEngineConfiguration deConfiguration) {
-		this.deConfiguration = deConfiguration;
-	}
-
-	public String getTopicName() {
-		return topicName;
-	}
-
-	public void setTopicName(String topicName) {
-		this.topicName = topicName;
-	}
-
-	public String getUserId() {
-		return userId;
-	}
-
-	public void setUserId(String userId) {
-		this.userId = userId;
-	}
-
-	public String getModifierName() {
-		return modifierName;
-	}
-
-	public void setModifierName(String modifierName) {
-		this.modifierName = modifierName;
-	}
-
-	@Override
-	public void run() {
-
-		long startTime = System.currentTimeMillis();
-		ThreadLocalsHolder.setUuid(this.requestId);
-
-		CambriaErrorResponse status = cambriaHandler.sendNotificationAndClose(topicName, deConfiguration.getUebPublicKey(), deConfiguration.getUebSecretKey(), deConfiguration.getUebServers(), data,
-				deConfiguration.getDistributionNotificationTopic().getMaxWaitingAfterSendingSeconds());
-
-		logger.info("After publishing service {} of version {}. Status is {}", service.getName(), service.getVersion(), status.getHttpCode());
-		auditDistributionNotification(topicName, status, service, distributionId, envName, userId, modifierName);
-
-		long endTime = System.currentTimeMillis();
-		logger.debug("After building and publishing artifacts object. Total took {} milliseconds", (endTime - startTime));
-
-	}
-
-	private void auditDistributionNotification(String topicName, CambriaErrorResponse status, Service service, String distributionId, String envName, String userId, String modifierName) {
-		if (this.componentUtils != null) {
-			Integer httpCode = status.getHttpCode();
-			String httpCodeStr = String.valueOf(httpCode);
-
-			String desc = getDescriptionFromErrorResponse(status);
-
-			this.componentUtils.auditDistributionNotification(AuditingActionEnum.DISTRIBUTION_NOTIFY, service.getUUID(), service.getName(), "Service", service.getVersion(), userId, modifierName, envName, service.getLifecycleState().name(), topicName,
-					distributionId, desc, httpCodeStr);
-		}
-	}
-
-	private String getDescriptionFromErrorResponse(CambriaErrorResponse status) {
-
-		CambriaOperationStatus operationStatus = status.getOperationStatus();
-
-		switch (operationStatus) {
-		case OK:
-			return "OK";
-		case AUTHENTICATION_ERROR:
-			return "Error: Authentication problem towards U-EB server";
-		case INTERNAL_SERVER_ERROR:
-			return "Error: Internal U-EB server error";
-		case UNKNOWN_HOST_ERROR:
-			return "Error: Cannot reach U-EB server host";
-		case CONNNECTION_ERROR:
-			return "Error: Cannot connect to U-EB server";
-		case OBJECT_NOT_FOUND:
-			return "Error: object not found in U-EB server";
-		default:
-			return "Error: Internal Cambria server problem";
-
-		}
-
-	}
-}