<layout class="com.att.nsa.logging.log4j.EcompLayout"><param name="ConversionPattern" value="ECOMP_DEBUG" /></layout>
</appender>
- <logger name="org.onap.dcae.commonFunction.input" additivity="false">
+ <logger name="org.onap.dcae.common.input" additivity="false">
<level value="INFO"/>
<appender-ref ref="IFILE"/>
</logger>
- <logger name="org.onap.dcae.commonFunction.output" additivity="false">
+ <logger name="org.onap.dcae.common.output" additivity="false">
<level value="INFO"/>
<appender-ref ref="CONSOLE" />
<appender-ref ref="OFILE"/>
</logger>
- <logger name="org.onap.dcae.commonFunction.error" additivity="false">
+ <logger name="org.onap.dcae.common.error" additivity="false">
<level value="DEBUG"/>
<appender-ref ref="EFILE"/>
<appender-ref ref="CONSOLE" />
<appender-ref ref="ECOMP_DEBUG" />
</logger>
- <logger name="org.onap.dcae.commonFunction.EventPublisher" additivity="false">
+ <logger name="org.onap.dcae.common.EventPublisher" additivity="false">
<level value="debug"/>
<appender-ref ref="CONSOLE" />
</logger>
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.json.JSONObject;
-import org.onap.dcae.commonFunction.EventProcessor;
-import org.onap.dcae.commonFunction.EventSender;
-import org.onap.dcae.commonFunction.event.publishing.DMaaPConfigurationParser;
-import org.onap.dcae.commonFunction.event.publishing.EventPublisher;
-import org.onap.dcae.commonFunction.event.publishing.PublisherConfig;
+import org.onap.dcae.common.EventProcessor;
+import org.onap.dcae.common.EventSender;
+import org.onap.dcae.common.publishing.DMaaPConfigurationParser;
+import org.onap.dcae.common.publishing.EventPublisher;
+import org.onap.dcae.common.publishing.PublisherConfig;
import org.onap.dcae.controller.ConfigLoader;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class VesApplication {
private static final Logger metriclog = LoggerFactory.getLogger("com.att.ecomp.metrics");
- private static final Logger incomingRequestsLogger = LoggerFactory.getLogger("org.onap.dcae.commonFunction.input");
- private static final Logger oplog = LoggerFactory.getLogger("org.onap.dcae.commonFunction.output");
- private static final Logger errorLog = LoggerFactory.getLogger("org.onap.dcae.commonFunction.error");
+ private static final Logger incomingRequestsLogger = LoggerFactory.getLogger("org.onap.dcae.common.input");
+ private static final Logger oplog = LoggerFactory.getLogger("org.onap.dcae.common.output");
+ private static final Logger errorLog = LoggerFactory.getLogger("org.onap.dcae.common.error");
private static final int MAX_THREADS = 20;
public static LinkedBlockingQueue<JSONObject> fProcessingInputQueue;
private static ApplicationSettings properties;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import io.vavr.collection.List;
import io.vavr.collection.Set;
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import java.lang.reflect.Method;
import org.json.JSONObject;
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import org.json.JSONArray;
import org.json.JSONObject;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import com.google.gson.JsonObject;
* ============LICENSE_END=========================================================\r
*/\r
\r
-package org.onap.dcae.commonFunction;\r
+package org.onap.dcae.common;\r
\r
import com.att.nsa.clock.SaClock;\r
import com.att.nsa.logging.LoggingContext;\r
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import com.google.common.reflect.TypeToken;
import com.google.gson.Gson;
import io.vavr.collection.Map;
-import io.vavr.control.Option;
import java.io.FileReader;
import java.io.IOException;
import java.lang.reflect.Type;
import java.text.SimpleDateFormat;
-import java.util.Arrays;
import java.util.Date;
import java.util.List;
-import java.util.Optional;
import org.json.JSONObject;
import org.onap.dcae.ApplicationSettings;
-import org.onap.dcae.commonFunction.event.publishing.EventPublisher;
+import org.onap.dcae.common.publishing.EventPublisher;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import com.google.gson.JsonObject;
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import org.springframework.boot.web.server.Ssl;
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import com.att.nsa.clock.SaClock;
import com.att.nsa.logging.LoggingContext;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import io.vavr.collection.List;
import io.vavr.collection.Map;
import io.vavr.control.Option;
import io.vavr.control.Try;
-import org.onap.dcae.commonFunction.AnyNode;
+import org.onap.dcae.common.AnyNode;
import java.net.URL;
import java.nio.file.Files;
import org.json.JSONObject;
import static io.vavr.API.*;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.enhanceError;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.enhanceError;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
/**
* @author Pawel Szalapski (pawel.szalapski@nokia.com)
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import com.att.nsa.cambria.client.CambriaBatchingPublisher;
import com.att.nsa.clock.SaClock;
import io.vavr.collection.Map;
import io.vavr.control.Try;
import org.json.JSONObject;
-import org.onap.dcae.commonFunction.VESLogger;
+import org.onap.dcae.common.VESLogger;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
/**
* @author Pawel Szalapski (pawel.szalapski@nokia.com)
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import com.att.nsa.cambria.client.CambriaBatchingPublisher;
import com.att.nsa.cambria.client.CambriaClientBuilders;
import io.vavr.control.Try;
import static io.vavr.API.Try;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.enhanceError;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.enhanceError;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
/**
* @author Pawel Szalapski (pawel.szalapski@nokia.com)
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import com.att.nsa.cambria.client.CambriaBatchingPublisher;
import com.google.common.cache.*;
import java.util.concurrent.atomic.AtomicReference;
import static io.vavr.API.Option;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
/**
* @author Pawel Szalapski (pawel.szalapski@nokia.com)
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import io.vavr.collection.Map;
import org.json.JSONObject;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import io.vavr.collection.List;
import io.vavr.control.Option;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import io.vavr.API;
import io.vavr.API.Match.Case;
-import io.vavr.Function0;
-import io.vavr.Function1;
import java.util.function.Consumer;
-import java.util.function.Function;
import org.slf4j.Logger;
import static io.vavr.API.$;
import java.nio.file.Path;
import static io.vavr.API.Try;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.*;
+import static org.onap.dcae.common.publishing.VavrUtils.*;
import static org.onap.dcae.controller.Conversions.toList;
class ConfigFilesFacade {
*/
package org.onap.dcae.controller;
-import static org.onap.dcae.commonFunction.event.publishing.DMaaPConfigurationParser.parseToDomainMapping;
+import static org.onap.dcae.common.publishing.DMaaPConfigurationParser.parseToDomainMapping;
import static org.onap.dcae.controller.ConfigParsing.getDMaaPConfig;
import static org.onap.dcae.controller.ConfigParsing.getProperties;
import static org.onap.dcae.controller.EnvPropertiesReader.readEnvProps;
import java.nio.file.Path;
import java.util.function.Consumer;
import org.json.JSONObject;
-import org.onap.dcae.commonFunction.event.publishing.EventPublisher;
-import org.onap.dcae.commonFunction.event.publishing.PublisherConfig;
+import org.onap.dcae.common.publishing.PublisherConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import static io.vavr.API.Try;
import static io.vavr.API.Tuple;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
import static org.onap.dcae.controller.Conversions.toList;
import io.vavr.collection.Map;
package org.onap.dcae.controller;
import static io.vavr.API.Try;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.enhanceError;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.enhanceError;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
import static org.onap.dcae.controller.Conversions.toJson;
import static org.onap.dcae.controller.Conversions.toJsonArray;
*/
package org.onap.dcae.controller;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.enhanceError;
+import static org.onap.dcae.common.publishing.VavrUtils.enhanceError;
import io.vavr.API;
import io.vavr.collection.List;
import static io.vavr.API.List;
import static io.vavr.API.Try;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
final class EnvPropertiesReader {
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.function.Consumer;
-import org.onap.dcae.commonFunction.event.publishing.PublisherConfig;
+import org.onap.dcae.common.publishing.PublisherConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
package org.onap.dcae.restapi;
import org.onap.dcae.ApplicationSettings;
-import org.onap.dcae.commonFunction.SSLContextCreator;
+import org.onap.dcae.common.SSLContextCreator;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.json.JSONArray;
import org.json.JSONObject;
import org.onap.dcae.ApplicationSettings;
-import org.onap.dcae.commonFunction.VESLogger;
+import org.onap.dcae.common.VESLogger;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import static org.junit.Assert.assertEquals;
// ============LICENSE_END=========================================================
//
//
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.times;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction;
+package org.onap.dcae.common;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.never;
import org.mockito.Mock;
import org.mockito.junit.MockitoJUnitRunner;
import org.onap.dcae.ApplicationSettings;
-import org.onap.dcae.commonFunction.event.publishing.EventPublisher;
+import org.onap.dcae.common.publishing.EventPublisher;
@RunWith(MockitoJUnitRunner.Silent.class)
public class EventSenderTest {
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import static io.vavr.API.List;
import static org.assertj.core.api.Assertions.assertThat;
-import static org.onap.dcae.commonFunction.event.publishing.DMaaPConfigurationParser.parseToDomainMapping;
+import static org.onap.dcae.common.publishing.DMaaPConfigurationParser.parseToDomainMapping;
import io.vavr.collection.Map;
import io.vavr.control.Try;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import static io.vavr.API.Option;
import static org.mockito.ArgumentMatchers.anyString;
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-package org.onap.dcae.commonFunction.event.publishing;
+package org.onap.dcae.common.publishing;
import static io.vavr.API.List;
import static io.vavr.API.Map;
import java.util.concurrent.TimeUnit;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dcae.commonFunction.event.publishing.DMaaPPublishersCache.CambriaPublishersCacheLoader;
-import org.onap.dcae.commonFunction.event.publishing.DMaaPPublishersCache.OnPublisherRemovalListener;
+import org.onap.dcae.common.publishing.DMaaPPublishersCache.CambriaPublishersCacheLoader;
+import org.onap.dcae.common.publishing.DMaaPPublishersCache.OnPublisherRemovalListener;
public class DMaaPPublishersCacheTest {
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyZeroInteractions;
-import static org.mockito.Mockito.when;
import static org.onap.dcae.TestingUtilities.createTemporaryFile;
import static org.onap.dcae.TestingUtilities.readFile;
import static org.onap.dcae.TestingUtilities.readJSONFromFile;
-import static org.onap.dcae.commonFunction.event.publishing.VavrUtils.f;
+import static org.onap.dcae.common.publishing.VavrUtils.f;
import java.nio.file.Path;
import java.nio.file.Paths;
import org.json.JSONObject;
import org.junit.Test;
import org.onap.dcae.WiremockBasedTest;
-import org.onap.dcae.commonFunction.event.publishing.DMaaPConfigurationParser;
-import org.onap.dcae.commonFunction.event.publishing.EventPublisher;
+import org.onap.dcae.common.publishing.DMaaPConfigurationParser;
+import org.onap.dcae.common.publishing.EventPublisher;
public class ConfigLoaderIntegrationE2ETest extends WiremockBasedTest {
import java.util.Set;
import org.junit.BeforeClass;
import org.junit.Test;
-import org.onap.dcae.commonFunction.AnyNode;
+import org.onap.dcae.common.AnyNode;
/**
* Created by koblosz on 07.06.18.
import java.io.IOException;\r
import org.json.JSONObject;\r
import org.junit.Test;\r
-import org.onap.dcae.commonFunction.ConfigProcessors;\r
+import org.onap.dcae.common.ConfigProcessors;\r
\r
public class TestConfigProcessor {\r
\r
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNotSame;
-import static org.onap.dcae.commonFunction.VESLogger.REQUEST_ID;
+import static org.onap.dcae.common.VESLogger.REQUEST_ID;
import com.att.nsa.logging.LoggingContext;
import com.att.nsa.logging.log4j.EcompFields;
import java.util.UUID;
import org.junit.Test;
-import org.onap.dcae.commonFunction.VESLogger;
+import org.onap.dcae.common.VESLogger;
public class TestVESLogger {