* 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.
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 {
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);
}