summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att/dmf/mr/listener/DME2EndPointLoader.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/att/dmf/mr/listener/DME2EndPointLoader.java')
-rw-r--r--src/main/java/com/att/dmf/mr/listener/DME2EndPointLoader.java123
1 files changed, 0 insertions, 123 deletions
diff --git a/src/main/java/com/att/dmf/mr/listener/DME2EndPointLoader.java b/src/main/java/com/att/dmf/mr/listener/DME2EndPointLoader.java
deleted file mode 100644
index f61b6ea..0000000
--- a/src/main/java/com/att/dmf/mr/listener/DME2EndPointLoader.java
+++ /dev/null
@@ -1,123 +0,0 @@
-/*******************************************************************************
- * ============LICENSE_START=======================================================
- * org.onap.dmaap
- * ================================================================================
- * Copyright © 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=========================================================
- *
- * ECOMP is a trademark and service mark of AT&T Intellectual Property.
- *
- *******************************************************************************/
-package com.att.dmf.mr.listener;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.Properties;
-
-import com.att.aft.dme2.manager.registry.DME2EndpointRegistry;
-import com.att.aft.dme2.api.DME2Exception;
-import com.att.aft.dme2.api.DME2Manager;
-import com.att.dmf.mr.service.impl.EventsServiceImpl;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-
-/**
- *
- * @author anowarul.islam
- *
- */
-public class DME2EndPointLoader {
-
- private String latitude;
- private String longitude;
- private String version;
- private String serviceName;
- private String env;
- private String routeOffer;
- private String hostName;
- private String port;
- private String contextPath;
- private String protocol;
- private String serviceURL;
- private static DME2EndPointLoader loader = new DME2EndPointLoader();
-
- private static final EELFLogger LOG = EELFManager.getInstance().getLogger(EventsServiceImpl.class);
- private DME2EndPointLoader() {
- }
-
- public static DME2EndPointLoader getInstance() {
- return loader;
- }
-
- /**
- * publishing endpoints
- */
- public void publishEndPoints() {
-
- try {
- InputStream input = this.getClass().getResourceAsStream("/endpoint.properties");
- Properties props = new Properties();
- props.load(input);
-
- latitude = props.getProperty("Latitude");
- longitude = props.getProperty("Longitude");
- version = props.getProperty("Version");
- serviceName = props.getProperty("ServiceName");
- env = props.getProperty("Environment");
- routeOffer = props.getProperty("RouteOffer");
- hostName = props.getProperty("HostName");
- port = props.getProperty("Port");
- contextPath = props.getProperty("ContextPath");
- protocol = props.getProperty("Protocol");
-
- System.setProperty("AFT_LATITUDE", latitude);
- System.setProperty("AFT_LONGITUDE", longitude);
- System.setProperty("AFT_ENVIRONMENT", "AFTUAT");
-
- serviceURL = "service=" + serviceName + "/" + "version=" + version + "/" + "envContext=" + env + "/"
- + "routeOffer=" + routeOffer;
-
- DME2Manager manager = new DME2Manager("testEndpointPublish", props);
- manager.setClientCredentials("sh301n", "");
- DME2EndpointRegistry svcRegistry = manager.getEndpointRegistry();
- // Publish API takes service name, context path, hostname, port and
- // protocol as args
- svcRegistry.publish(serviceURL, contextPath, hostName, Integer.parseInt(port), protocol);
-
- } catch (IOException | DME2Exception e) {
- LOG.error("Failed due to :" + e);
- }
-
- }
-/**
- * unpublishing endpoints
- */
- public void unPublishEndPoints() {
-
- DME2Manager manager;
- try {
- System.setProperty("AFT_LATITUDE", latitude);
- System.setProperty("AFT_LONGITUDE", longitude);
- System.setProperty("AFT_ENVIRONMENT", "AFTUAT");
-
- manager = DME2Manager.getDefaultInstance();
- DME2EndpointRegistry svcRegistry = manager.getEndpointRegistry();
- svcRegistry.unpublish(serviceURL, hostName, Integer.parseInt(port));
- } catch (DME2Exception e) {
- LOG.error("Failed due to DME2Exception" + e);
- }
-
- }
-
-}