1 files changed, 17 insertions, 3 deletions
diff --git a/src/test/java/org/onap/dcae/common/publishing/DMaapContainer.java b/src/test/java/org/onap/dcae/common/publishing/DMaapContainer.java
index 9ece10b5..404b0ed7 100644
--- a/src/test/java/org/onap/dcae/common/publishing/DMaapContainer.java
+++ b/src/test/java/org/onap/dcae/common/publishing/DMaapContainer.java
@@ -3,6 +3,7 @@
  * VES Collector
  * =========================================================
  * Copyright (C) 2019-2021 Nokia. All rights reserved.
+ * Copyright (C) 2023 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.
@@ -20,9 +21,14 @@
 
 package org.onap.dcae.common.publishing;
 
+import org.onap.dcae.FileReader;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.DockerComposeContainer;
 
 import java.io.File;
+import java.net.URI;
+import java.net.URISyntaxException;
 import java.net.URL;
 
 final class DMaapContainer {
@@ -30,13 +36,21 @@ final class DMaapContainer {
     private static final String DOCKER_COMPOSE_FILE_PATH = getDockerComposeFilePath(MR_COMPOSE_RESOURCE_NAME);
     static final int DMAAP_SERVICE_EXPOSED_PORT = 3904;
     static final String DMAAP_SERVICE_NAME = "onap-dmaap";
-
+    private static final Logger log = LoggerFactory.getLogger(DMaapContainer.class);
+    
     private DMaapContainer() {}
 
 
-    public static DockerComposeContainer createContainerInstance(){
+    public static DockerComposeContainer createContainerInstance() {
+
+        URI dockercomposeuri = null;
+        try {
+            dockercomposeuri = new URI(DOCKER_COMPOSE_FILE_PATH);
+        } catch (URISyntaxException e) {
+            log.error("Error while opening docker compose file.", e);
+        }
         return new DockerComposeContainer(
-                new File(DOCKER_COMPOSE_FILE_PATH))
+                new File(dockercomposeuri.getPath()))
                 .withExposedService(DMAAP_SERVICE_NAME, DMAAP_SERVICE_EXPOSED_PORT)
                 .withLocalCompose(true);
     }