Fetch mapper config from configbinding service

Change-Id: I69e654719969f2d0ef6e7c8adb4806aac9c1e898
Issue-ID: DCAEGEN2-1081
Signed-off-by: emartin <ephraim.martin@est.tech>

13 files changed, 494 insertions, 7 deletions

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/App.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/App.java
index 2b93d03..1c837e4 100644
--- a/src/main/java/org/onap/dcaegen2/services/pmmapper/App.java
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/App.java
@@ -23,24 +23,33 @@ package org.onap.dcaegen2.services.pmmapper;
 import io.undertow.Handlers;
 import io.undertow.Undertow;
 import io.undertow.util.StatusCodes;
-import org.onap.dcaegen2.services.pmmapper.config.BusControllerConfig;
+
+import org.onap.dcaegen2.services.pmmapper.config.ConfigHandler;
 import org.onap.dcaegen2.services.pmmapper.datarouter.DataRouterSubscriber;
+import org.onap.dcaegen2.services.pmmapper.exceptions.CBSConfigException;
+import org.onap.dcaegen2.services.pmmapper.exceptions.CBSServerError;
+import org.onap.dcaegen2.services.pmmapper.exceptions.ConsulServerError;
+import org.onap.dcaegen2.services.pmmapper.exceptions.EnvironmentConfigException;
+import org.onap.dcaegen2.services.pmmapper.exceptions.MapperConfigException;
 import org.onap.dcaegen2.services.pmmapper.exceptions.TooManyTriesException;
+import org.onap.dcaegen2.services.pmmapper.model.BusControllerConfig;
+import org.onap.dcaegen2.services.pmmapper.model.MapperConfig;
 
 import java.net.MalformedURLException;
 import java.net.URL;
 
 public class App {
 
-    public static void main(String[] args) throws MalformedURLException, InterruptedException, TooManyTriesException {
+    public static void main(String[] args) throws MalformedURLException, InterruptedException, TooManyTriesException, CBSConfigException, ConsulServerError, EnvironmentConfigException, CBSServerError, MapperConfigException {
         DataRouterSubscriber dataRouterSubscriber = new DataRouterSubscriber(event -> {
             event.getHttpServerExchange().unDispatch();
             event.getHttpServerExchange().getResponseSender().send(StatusCodes.OK_STRING);
             System.out.println(event.getMetadata().getProductName());
         });
-        BusControllerConfig config = new BusControllerConfig();
-        config.setDataRouterSubscribeEndpoint(new URL("http://" + System.getenv("DMAAP_BC_SERVICE_HOST") + ":" + System.getenv("DMAAP_BC_SERVICE_PORT") + "/webapi/dr_subs"));
-        dataRouterSubscriber.start(config);
+        MapperConfig mapperConfig = new ConfigHandler().getMapperConfig();
+        BusControllerConfig busConfig =  mapperConfig.getBusControllerConfig();
+        busConfig.setDataRouterSubscribeEndpoint(new URL("http://" + System.getenv("DMAAP_BC_SERVICE_HOST") + ":" + System.getenv("DMAAP_BC_SERVICE_PORT") + "/webapi/dr_subs"));
+        dataRouterSubscriber.start(busConfig);
 
         Undertow.builder()
                 .addHttpListener(8081, "0.0.0.0")
diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/config/ConfigHandler.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/config/ConfigHandler.java
new file mode 100644
index 0000000..847fff2
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/config/ConfigHandler.java
@@ -0,0 +1,133 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.config;

+

+import java.util.Arrays;

+import org.onap.dcaegen2.services.pmmapper.exceptions.CBSConfigException;

+import org.onap.dcaegen2.services.pmmapper.exceptions.CBSServerError;

+import org.onap.dcaegen2.services.pmmapper.exceptions.ConsulServerError;

+import org.onap.dcaegen2.services.pmmapper.exceptions.EnvironmentConfigException;

+import org.onap.dcaegen2.services.pmmapper.exceptions.MapperConfigException;

+import org.onap.dcaegen2.services.pmmapper.model.CBSConfig;

+import org.onap.dcaegen2.services.pmmapper.model.EnvironmentConfig;

+import org.onap.dcaegen2.services.pmmapper.model.MapperConfig;

+import org.onap.dcaegen2.services.pmmapper.utils.RequestSender;

+import org.onap.dcaegen2.services.pmmapper.utils.RequiredFieldDeserializer;

+import com.google.gson.GsonBuilder;

+import lombok.extern.slf4j.Slf4j;

+

+/**

+ * Handles the retrieval of the component spec-based PM-Mapper Configuration

+ * from DCAE.

+ */

+@Slf4j

+public class ConfigHandler {

+    private RequestSender sender;

+

+    /**

+     * Creates a ConfigHandler.

+     */

+    public ConfigHandler() {

+        this(new RequestSender());

+    }

+

+    /**

+     * @see ConfigHandler#ConfigHandler()

+     * @param sender A RequestSender

+     */

+    public ConfigHandler(RequestSender sender) {

+        this.sender = sender;

+    }

+

+    /**

+     * Retrieves PM-Mapper Configuration from DCAE's ConfigBinding Service.

+     *
+     * @throws EnvironmentConfigException

+     * @throws ConsulServerError

+     * @throws CBSConfigException

+     * @throws CBSServerError

+     * @throws MapperConfigException

+     */
+    public MapperConfig getMapperConfig() throws CBSConfigException, ConsulServerError, EnvironmentConfigException,

+            CBSServerError, MapperConfigException {

+        CBSConfig cbsConfig = convertCBSConfigToObject(getCBSConfigFromConsul());

+        String cbsSocketAddress = cbsConfig.getServiceAddress() + ":" + cbsConfig.getServicePort();

+        String requestURL = "http://" + cbsSocketAddress + "/service_component/" + cbsConfig.getServiceName();

+        String mapperConfigJson = "";

+        log.debug("Fetching mapper configuration from CBS: " + requestURL);

+        try {

+            mapperConfigJson = sender.send(requestURL);

+        } catch (Exception exception) {

+            throw new CBSServerError("Error connecting to Configbinding Service: ", exception);

+        }

+

+        return convertMapperConfigToObject(mapperConfigJson);

+    }

+

+    private String getCBSConfigFromConsul() throws ConsulServerError, EnvironmentConfigException {

+        String cbsParams;

+        String consulURL = "http://" + EnvironmentConfig.getConsulHost() + ":" + EnvironmentConfig.getConsultPort()

+                + "/v1/catalog/service/" + EnvironmentConfig.getCbsName();

+        log.debug(consulURL);

+        try {

+            cbsParams = sender.send(consulURL);

+        } catch (Exception exception) {

+            throw new ConsulServerError("Error connecting to Consul: ", exception);

+        }

+

+        log.debug("cbsConfig: " + cbsParams);

+        return cbsParams;

+    }

+

+    private MapperConfig convertMapperConfigToObject(String mapperConfigJson) throws MapperConfigException {

+        log.debug("mapperConfigJson:" + mapperConfigJson);

+        MapperConfig mapperConfig;

+        try {

+            mapperConfig = new GsonBuilder()

+                    .registerTypeAdapter(MapperConfig.class, new RequiredFieldDeserializer<MapperConfig>())

+                    .create()

+                    .fromJson(mapperConfigJson, MapperConfig.class);

+        } catch (Exception exception) {

+            throw new MapperConfigException("Error parsing mapper configuration: " + mapperConfigJson, exception);

+        }

+

+        log.debug("\n" + mapperConfig.toString());

+        return mapperConfig;

+    }

+

+    private CBSConfig convertCBSConfigToObject(String cbsParameters) throws CBSConfigException {

+        CBSConfig cbsConfig;

+        try {

+            cbsConfig = Arrays

+                    .asList(new GsonBuilder()

+                            .registerTypeAdapter(CBSConfig.class, new RequiredFieldDeserializer<CBSConfig>())

+                            .create()

+                            .fromJson(cbsParameters, CBSConfig[].class))

+                    .get(0);

+            log.debug("\n\nReceived ConfigBinding Service Configurations: " + cbsConfig);

+        } catch (Exception exception) {

+            throw new CBSConfigException(

+                    "Error mapping the received ConfigBinding service configuration parameters: " + cbsParameters,

+                    exception);

+        }

+        return cbsConfig;

+    }

+

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DataRouterSubscriber.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DataRouterSubscriber.java
index 1d27d3b..f063a23 100644
--- a/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DataRouterSubscriber.java
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/datarouter/DataRouterSubscriber.java
@@ -27,10 +27,11 @@ import com.google.gson.JsonParseException;
 import io.undertow.util.HeaderValues;
 import lombok.Data;
 import lombok.NonNull;
-import org.onap.dcaegen2.services.pmmapper.config.BusControllerConfig;
+
 import org.onap.dcaegen2.services.pmmapper.exceptions.NoMetadataException;
 import org.onap.dcaegen2.services.pmmapper.exceptions.TooManyTriesException;
 import org.onap.dcaegen2.services.pmmapper.model.EventMetadata;
+import org.onap.dcaegen2.services.pmmapper.model.BusControllerConfig;
 import org.onap.dcaegen2.services.pmmapper.model.Event;
 import io.undertow.server.HttpHandler;
 import io.undertow.server.HttpServerExchange;
diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/CBSConfigException.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/CBSConfigException.java
new file mode 100644
index 0000000..99bb8a7
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/CBSConfigException.java
@@ -0,0 +1,26 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.exceptions;

+

+public class CBSConfigException extends Exception {

+    public CBSConfigException(String message, Throwable cause) {

+        super(message, cause);

+    }

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/CBSServerError.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/CBSServerError.java
new file mode 100644
index 0000000..787d21f
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/CBSServerError.java
@@ -0,0 +1,26 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.exceptions;

+

+public class CBSServerError extends Exception {

+    public CBSServerError(String message, Throwable cause) {

+        super(message, cause);

+    }

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/ConsulServerError.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/ConsulServerError.java
new file mode 100644
index 0000000..4c2adab
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/ConsulServerError.java
@@ -0,0 +1,26 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.exceptions;

+

+public class ConsulServerError extends Exception {

+    public ConsulServerError(String message, Throwable cause) {

+        super(message, cause);

+    }

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/EnvironmentConfigException.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/EnvironmentConfigException.java
new file mode 100644
index 0000000..1a0d321
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/EnvironmentConfigException.java
@@ -0,0 +1,26 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.exceptions;

+

+public class EnvironmentConfigException extends Exception {

+    public EnvironmentConfigException(String message) {

+        super(message);

+    }

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/MapperConfigException.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/MapperConfigException.java
new file mode 100644
index 0000000..e78da98
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/exceptions/MapperConfigException.java
@@ -0,0 +1,26 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.exceptions;

+

+public class MapperConfigException extends Exception {

+    public MapperConfigException(String message, Throwable cause) {

+        super(message, cause);

+    }

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/config/BusControllerConfig.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/BusControllerConfig.java
index 63b2a32..3727099 100644
--- a/src/main/java/org/onap/dcaegen2/services/pmmapper/config/BusControllerConfig.java
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/BusControllerConfig.java
@@ -17,7 +17,7 @@
  * SPDX-License-Identifier: Apache-2.0
  * ============LICENSE_END=========================================================
  */
-package org.onap.dcaegen2.services.pmmapper.config;
+package org.onap.dcaegen2.services.pmmapper.model;
 
 import lombok.Data;
 
diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/model/CBSConfig.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/CBSConfig.java
new file mode 100644
index 0000000..66fbed4
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/CBSConfig.java
@@ -0,0 +1,46 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.model;

+

+import org.onap.dcaegen2.services.pmmapper.utils.GSONRequired;

+

+import com.google.gson.annotations.SerializedName;

+import lombok.Data;

+

+@Data

+public class CBSConfig {

+

+    @GSONRequired

+    @SerializedName("ServiceID")

+    private String serviceID;

+

+    @GSONRequired

+    @SerializedName("ServiceName")

+    private String serviceName;

+

+    @GSONRequired

+    @SerializedName("ServiceAddress")

+    private String serviceAddress;

+

+    @GSONRequired

+    @SerializedName("ServicePort")

+    private String servicePort;

+

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/model/EnvironmentConfig.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/EnvironmentConfig.java
new file mode 100644
index 0000000..f9dd178
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/EnvironmentConfig.java
@@ -0,0 +1,54 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.model;

+

+import java.util.Optional;

+

+import org.onap.dcaegen2.services.pmmapper.exceptions.EnvironmentConfigException;

+

+public class EnvironmentConfig {

+

+    private static Integer consulPort = 8500;

+

+    public static String getConsulHost() throws EnvironmentConfigException {

+        return Optional.ofNullable(System.getProperty("CONSUL_HOST"))

+                .orElseThrow(() -> new EnvironmentConfigException(

+                        "$CONSUL_HOST environment variable must be defined prior to pm-mapper initialization"));

+    }

+

+    public static Integer getConsultPort() throws EnvironmentConfigException {

+        Integer port = consulPort;

+        try {

+            port = Optional.ofNullable(System.getProperty("CONSUL_PORT"))

+                    .map(Integer::valueOf)

+                    .orElse(consulPort);

+        } catch (NumberFormatException e) {

+            throw new EnvironmentConfigException("CONSUL_PORT must be valid: " + port);

+        }

+        return port;

+

+    }

+

+    public static String getCbsName() throws EnvironmentConfigException {

+        return Optional.ofNullable(System.getProperty("CONFIG_BINDING_SERVICE"))

+                .orElseThrow(() -> new EnvironmentConfigException(

+                        "$CONFIG_BINDING_SERVICE environment variable must be defined prior to pm-mapper initialization."));

+    }

+}

diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/model/MapperConfig.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/MapperConfig.java
new file mode 100644
index 0000000..f8e428f
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/model/MapperConfig.java
@@ -0,0 +1,37 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.model;

+

+import org.onap.dcaegen2.services.pmmapper.utils.GSONRequired;

+import com.google.gson.annotations.SerializedName;

+import lombok.Data;

+import lombok.NoArgsConstructor;

+

+@Data

+@NoArgsConstructor

+public class MapperConfig {

+

+    @GSONRequired

+    @SerializedName("streams_subscribes.pm_mapper_handle_out.message_router_topic")

+    private String messageRouterTopicName;

+
+    BusControllerConfig busControllerConfig;

+

+}
\ No newline at end of file
diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/utils/RequestSender.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/utils/RequestSender.java
new file mode 100644
index 0000000..1b9cdc6
--- /dev/null
+++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/utils/RequestSender.java
@@ -0,0 +1,77 @@
+/*-

+ * ============LICENSE_START=======================================================

+ *  Copyright (C) 2019 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.dcaegen2.services.pmmapper.utils;

+

+import java.io.BufferedReader;

+import java.io.InputStream;

+import java.io.InputStreamReader;

+import java.net.HttpURLConnection;

+import java.net.URL;

+import java.util.stream.Collectors;

+import lombok.extern.slf4j.Slf4j;

+

+@Slf4j

+public class RequestSender {

+    private static final int MAX_RETRIES = 5;

+    private static final int RETRY_INTERVAL = 1000;

+    public static final String SERVER_ERROR_MESSAGE = "Error on Server";

+    public static final int ERROR_START_RANGE = 300;

+

+    /**

+     * Sends an Http GET request to a given endpoint.

+     *

+     * @return http response body

+     * @throws Exception

+     * @throws InterruptedException

+     */

+    public String send(final String url) throws Exception {

+        log.debug("RequestSender::send: " + url);

+        String result = "";

+        for (int i = 1; i <= MAX_RETRIES; i++) {

+            URL obj = new URL(url);

+            HttpURLConnection connection = (HttpURLConnection) obj.openConnection();

+            try (InputStream is = connection.getInputStream();

+                    BufferedReader reader = new BufferedReader(new InputStreamReader(is))) {

+                result = reader.lines()

+                        .collect(Collectors.joining("\n"));

+                int responseCode = connection.getResponseCode();

+                if (!(isWithinErrorRange(responseCode))) {

+                    break;

+                }

+

+            } catch (Exception e) {
+                if (retryLimitReached(i)) {

+                    throw new Exception(SERVER_ERROR_MESSAGE + ": " + connection.getResponseMessage(), e);

+                }

+            }

+

+            Thread.sleep(RETRY_INTERVAL);

+        }

+        return result;

+    }

+

+    private boolean retryLimitReached(final int retryCount) {

+        return retryCount >= MAX_RETRIES;

+    }

+

+    private boolean isWithinErrorRange(final int responseCode) {

+        return responseCode >= ERROR_START_RANGE;

+    }

+}