<modelVersion>4.0.0</modelVersion>
<groupId>org.onap.dmaap.messagerouter.msgrtr</groupId>
<artifactId>msgrtr</artifactId>
- <version>0.0.5</version>
+ <version>1.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
<name>Message Router</name>
<description>Message Router - Restful interface built for kafka</description>
- <url>https://github.com/att/dmaap-framework</url>
+
+ <parent>
+ <groupId>org.onap.oparent</groupId>
+ <artifactId>oparent</artifactId>
+ <version>1.0.0-SNAPSHOT</version>
+ </parent>
+
<properties>
<spring.version>3.2.14.RELEASE</spring.version>
<cxf.version>3.0.4</cxf.version>
<maven.compiler.target>1.7</maven.compiler.target>
<maven.compiler.source>1.7</maven.compiler.source>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <nexusproxy>https://nexus.onap.org</nexusproxy>
- <snapshotNexusPath>/content/repositories/snapshots/</snapshotNexusPath>
- <releaseNexusPath>/content/repositories/releases/</releaseNexusPath>
- <stagingNexusPath>/content/repositories/staging/</stagingNexusPath>
- <sitePath>/content/sites/site/org/onap/datarouter/${project.artifactId}/${project.version}</sitePath>
</properties>
<!-- Distribution management -->
<licenses>
<license>
- <name>Apache License 2.0</name>
+ <name>Apache License Version 2.0</name>
</license>
</licenses>
<organizationUrl>www.att.com</organizationUrl>
</developer>
</developers>
- <distributionManagement>
- <repository>
- <id>ecomp-releases</id>
- <name>AAF Release Repository</name>
- <url>${nexusproxy}${releaseNexusPath}</url>
- </repository>
- <snapshotRepository>
- <id>ecomp-snapshots</id>
- <name>AAF Snapshot Repository</name>
- <url>${nexusproxy}${snapshotNexusPath}</url>
- </snapshotRepository>
- <site>
- <id>ecomp-site</id>
- <url>dav:${nexusproxy}${sitePath}</url>
- </site>
- </distributionManagement>
-
- <pluginRepositories>
- <pluginRepository>
- <id>onap-plugin-snapshots</id>
- <url>https://nexus.onap.org/content/repositories/snapshots/</url>
- </pluginRepository>
- </pluginRepositories>
<dependencies>
<!-- <phase>package</phase> bind to the packaging phase <goals> <goal>single</goal>
</goals> </execution> </executions> </plugin> -->
<!-- -->
- <plugin>
- <groupId>org.sonatype.plugins</groupId>
- <artifactId>nexus-staging-maven-plugin</artifactId>
- <version>1.6.7</version>
- <extensions>true</extensions>
- <configuration>
- <nexusUrl>${nexusproxy}</nexusUrl>
- <stagingProfileId>176c31dfe190a</stagingProfileId>
- <serverId>ecomp-staging</serverId>
- </configuration>
- </plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-javadoc-plugin</artifactId>
<!-- <skipTests>true</skipTests> -->
</configuration>
</plugin>
- <plugin>
- <groupId>org.codehaus.mojo</groupId>
- <artifactId>cobertura-maven-plugin</artifactId>
- <version>2.7</version>
- <configuration>
- <formats>
- <format>html</format>
- <format>xml</format>
- </formats>
- </configuration>
- </plugin>
- <plugin>
- <groupId>org.jacoco</groupId>
- <artifactId>jacoco-maven-plugin</artifactId>
- <version>0.6.2.201302030002</version>
- <configuration>
- <destfile>${basedir}/target/coverage-reports/jacoco-unit.exec</destfile>
- <datafile>${basedir}/target/coverage-reports/jacoco-unit.exec</datafile>
- </configuration>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-gpg-plugin</artifactId>
- <version>1.5</version>
- <executions>
- <execution>
- <id>sign-artifacts</id>
- <phase>verify</phase>
- <goals>
- <goal>sign</goal>
- </goals>
- </execution>
- </executions>
- </plugin>
-
+ <plugin>
+ <groupId>org.codehaus.mojo</groupId>
+ <artifactId>cobertura-maven-plugin</artifactId>
+ <version>2.7</version>
+ <configuration>
+ <formats>
+ <format>html</format>
+ <format>xml</format>
+ </formats>
+ </configuration>
+ </plugin>
</plugins>
</build>
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.apiServer.metrics.cambria;
+package com.att.nsa.apiServer.metrics.cambria;
import java.io.IOException;
import java.net.InetAddress;
import org.json.JSONObject;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.CambriaPublisher;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.DMaaPCambriaClientFactory;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
-import com.att.nsa.apiServer.metrics.cambria.MetricsSender;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.metrics.publisher.CambriaPublisher;
+import com.att.nsa.cambria.metrics.publisher.DMaaPCambriaClientFactory;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
import com.att.nsa.metrics.CdmMetricsRegistry;
import com.att.nsa.metrics.impl.CdmConstant;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria;
+package com.att.nsa.cambria;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
import com.att.nsa.apiServer.NsaAppException;
+import com.att.nsa.cambria.exception.ErrorResponse;
public class CambriaApiException extends NsaAppException
{
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria;
+package com.att.nsa.cambria;
import java.io.IOException;
import java.io.InputStream;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends;
+package com.att.nsa.cambria.backends;
/**
* A consumer interface. Consumers pull the next message from a given topic.
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends;
+package com.att.nsa.cambria.backends;
import java.util.Collection;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends;
+package com.att.nsa.cambria.backends;
import com.att.nsa.metrics.CdmMetricsRegistry;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends;
+package com.att.nsa.cambria.backends;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.LogDetails;
-
import kafka.producer.KeyedMessage;
+import com.att.nsa.cambria.beans.LogDetails;
+
/**
* A publisher interface. Publishers receive messages and post them to a topic.
* @author author
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka;
+package com.att.nsa.cambria.backends.kafka;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-
import kafka.consumer.ConsumerIterator;
import kafka.consumer.KafkaStream;
import kafka.javaapi.consumer.ConsumerConnector;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+import com.att.nsa.cambria.backends.Consumer;
+
/**
* A consumer instance that's created per-request. These are stateless so that
* clients can connect to this service as a proxy.
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka;
+package com.att.nsa.cambria.backends.kafka;
import java.io.IOException;
import java.util.Collection;
import org.apache.http.annotation.NotThreadSafe;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.KeeperException.NoNodeException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.MetricsSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
-
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.MetricsSet;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.utils.ConfigurationReader;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka;
+package com.att.nsa.cambria.backends.kafka;
import java.io.IOException;
import java.util.ArrayList;
import kafka.producer.ProducerConfig;
import org.json.JSONException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.springframework.beans.factory.annotation.Qualifier;
+import com.att.nsa.cambria.backends.Publisher;
+import com.att.nsa.cambria.constants.CambriaConstants;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory;
+package com.att.nsa.cambria.backends.memory;
import java.util.ArrayList;
import java.util.Collection;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.ConsumerFactory;
/**
*
* @author author
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory;
+package com.att.nsa.cambria.backends.memory;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.Set;
import java.util.TreeSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Topic;
-
+import com.att.nsa.cambria.metabroker.Broker;
+import com.att.nsa.cambria.metabroker.Topic;
import com.att.nsa.configs.ConfigDb;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
import com.att.nsa.security.NsaAcl;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory;
+package com.att.nsa.cambria.backends.memory;
import java.util.ArrayList;
import java.util.HashMap;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.Publisher.message;
/**
* When broker type is memory, then this class is doing all the topic related
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory;
+package com.att.nsa.cambria.backends.memory;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker.TopicExistsException;
+import com.att.nsa.cambria.backends.Publisher;
+import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
import kafka.producer.KeyedMessage;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory;
+package com.att.nsa.cambria.backends.memory;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher;
+import com.att.nsa.cambria.backends.Publisher;
import kafka.producer.KeyedMessage;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory;
+package com.att.nsa.cambria.backends.memory;
import java.io.File;
import java.io.FileNotFoundException;
import java.util.ArrayList;
import java.util.List;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher;
+import com.att.nsa.cambria.backends.Publisher;
import kafka.producer.KeyedMessage;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.io.Serializable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.util.HashMap;
import java.util.concurrent.TimeUnit;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPResponseCode;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.exception.DMaaPResponseCode;
+import com.att.nsa.cambria.exception.ErrorResponse;
import com.att.nsa.drumlin.service.standards.HttpStatusCodes;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
import com.att.nsa.drumlin.till.nv.rrNvReadable.invalidSettingValue;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
+import com.att.nsa.cambria.utils.ConfigurationReader;
/**
* DMaaPContext provide and maintain all the configurations , Http request/response
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.net.InetAddress;
import java.net.UnknownHostException;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.MetricsSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka.KafkaConsumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka.KafkaConsumerCache;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka.KafkaConsumerCache.KafkaConsumerCacheException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
-
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.springframework.beans.factory.annotation.Qualifier;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.ConsumerFactory;
+import com.att.nsa.cambria.backends.MetricsSet;
+import com.att.nsa.cambria.backends.kafka.KafkaConsumer;
+import com.att.nsa.cambria.backends.kafka.KafkaConsumerCache;
+import com.att.nsa.cambria.backends.kafka.KafkaConsumerCache.KafkaConsumerCacheException;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.utils.ConfigurationReader;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.util.LinkedList;
import java.util.List;
import org.json.JSONArray;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Topic;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
import org.springframework.beans.factory.annotation.Qualifier;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.metabroker.Broker;
+import com.att.nsa.cambria.metabroker.Topic;
+import com.att.nsa.cambria.utils.ConfigurationReader;
import com.att.nsa.configs.ConfigDb;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.configs.ConfigPath;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.apiServer.metrics.cambria.DMaaPMetricsSender;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiVersionInfo;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.MetricsSet;
-
+import com.att.nsa.apiServer.metrics.cambria.DMaaPMetricsSender;
+import com.att.nsa.cambria.CambriaApiVersionInfo;
+import com.att.nsa.cambria.backends.MetricsSet;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
import com.att.nsa.metrics.impl.CdmConstant;
import com.att.nsa.metrics.impl.CdmCounter;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.security.Key;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
//import org.apache.log4-j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+import com.att.nsa.cambria.constants.CambriaConstants;
import com.att.nsa.configs.ConfigDb;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.configs.confimpl.EncryptingLayer;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import org.I0Itec.zkclient.ZkClient;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
import org.springframework.beans.factory.annotation.Qualifier;
+import com.att.nsa.cambria.utils.ConfigurationReader;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
import org.springframework.beans.factory.annotation.Qualifier;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.utils.ConfigurationReader;
import com.att.nsa.configs.confimpl.ZkConfigDb;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
//import com.att.nsa.configs.confimpl.ZkConfigDb;
/**
*
*/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.util.Date;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.utils.Utils;
/**
* @author author
/**
*
*/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans;
+package com.att.nsa.cambria.beans;
import java.io.Serializable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants;
+package com.att.nsa.cambria.constants;
import org.apache.coyote.http11.Http11NioProtocol;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
+
+import com.att.nsa.cambria.utils.Utils;
/**
* This is the constant files for all the property or parameters.
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception;
+package com.att.nsa.cambria.exception;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.CambriaApiException;
public class DMaaPAccessDeniedException extends CambriaApiException{
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception;
+package com.att.nsa.cambria.exception;
import javax.inject.Singleton;
import javax.ws.rs.core.MediaType;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.apache.http.HttpStatus;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
+
import org.springframework.beans.factory.annotation.Autowired;
+import com.att.nsa.cambria.CambriaApiException;
+
/**
* Exception Mapper class to handle
* CambriaApiException
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception;
+package com.att.nsa.cambria.exception;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception;
+package com.att.nsa.cambria.exception;
/**
* Define the Error Response Codes for MR
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception;
+package com.att.nsa.cambria.exception;
import javax.inject.Singleton;
import javax.ws.rs.BadRequestException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception;
+package com.att.nsa.cambria.exception;
import org.json.JSONObject;
/**
* Represents the Error Response Object
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.listener;
+package com.att.nsa.cambria.listener;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.listener;
+package com.att.nsa.cambria.listener;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl.EventsServiceImpl;
-
import com.att.aft.dme2.api.DME2Exception;
import com.att.aft.dme2.api.DME2Manager;
import com.att.aft.dme2.manager.registry.DME2EndpointRegistry;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+import com.att.nsa.cambria.service.impl.EventsServiceImpl;
/**
*
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker;
+package com.att.nsa.cambria.metabroker;
import java.util.List;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-
+import com.att.nsa.cambria.CambriaApiException;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker;
+package com.att.nsa.cambria.metabroker;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.security.NsaAcl;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher;
+package com.att.nsa.cambria.metrics.publisher;
import java.io.IOException;
import java.util.List;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher;
+package com.att.nsa.cambria.metrics.publisher;
//import org.slf4j.Logger;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher;
+package com.att.nsa.cambria.metrics.publisher;
import java.io.IOException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher;
+package com.att.nsa.cambria.metrics.publisher;
import java.io.IOException;
import java.util.Collection;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher;
+package com.att.nsa.cambria.metrics.publisher;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher;
+package com.att.nsa.cambria.metrics.publisher;
import java.net.MalformedURLException;
import java.util.Collection;
import java.util.TreeSet;
import java.util.UUID;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.impl.DMaaPCambriaConsumerImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.impl.DMaaPCambriaSimplerBatchPublisher;
+import com.att.nsa.cambria.metrics.publisher.impl.DMaaPCambriaConsumerImpl;
+import com.att.nsa.cambria.metrics.publisher.impl.DMaaPCambriaSimplerBatchPublisher;
/**
* A factory for Cambria clients.<br/>
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.impl;
+package com.att.nsa.cambria.metrics.publisher.impl;
import java.net.MalformedURLException;
import java.util.Collection;
import org.json.JSONArray;
import org.json.JSONException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import com.att.nsa.apiClient.http.CacheUse;
import com.att.nsa.apiClient.http.HttpClient;
+import com.att.nsa.cambria.constants.CambriaConstants;
/**
*
* @author author
*
*/
-public class CambriaBaseClient extends HttpClient implements org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.CambriaClient
+public class CambriaBaseClient extends HttpClient implements com.att.nsa.cambria.metrics.publisher.CambriaClient
{
protected CambriaBaseClient ( Collection<String> hosts ) throws MalformedURLException
{
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.impl;
+package com.att.nsa.cambria.metrics.publisher.impl;
/**
*
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.impl;
+package com.att.nsa.cambria.metrics.publisher.impl;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.CambriaPublisherUtility;
import com.att.nsa.apiClient.http.HttpException;
import com.att.nsa.apiClient.http.HttpObjectNotFoundException;
+import com.att.nsa.cambria.metrics.publisher.CambriaPublisherUtility;
/**
*
*
*/
public class DMaaPCambriaConsumerImpl extends CambriaBaseClient
- implements org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.CambriaConsumer {
+ implements com.att.nsa.cambria.metrics.publisher.CambriaConsumer {
private final String fTopic;
private final String fGroup;
private final String fId;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.impl;
+package com.att.nsa.cambria.metrics.publisher.impl;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import javax.ws.rs.client.WebTarget;
import javax.ws.rs.core.Response;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.CambriaPublisherUtility;
-
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.metrics.publisher.CambriaPublisherUtility;
/**
*
*
*/
public class DMaaPCambriaSimplerBatchPublisher extends CambriaBaseClient
- implements org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metrics.publisher.CambriaBatchingPublisher {
+ implements com.att.nsa.cambria.metrics.publisher.CambriaBatchingPublisher {
/**
*
* static inner class initializes with urls, topic,batchSize
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources;
+package com.att.nsa.cambria.resources;
import java.io.IOException;
import java.io.InputStream;
import javax.servlet.http.HttpServletResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders.CambriaJsonStreamReader;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders.CambriaRawStreamReader;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders.CambriaStreamReader;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders.CambriaTextStreamReader;
-
import com.att.nsa.apiServer.streams.ChunkedInputStream;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.resources.streamReaders.CambriaJsonStreamReader;
+import com.att.nsa.cambria.resources.streamReaders.CambriaRawStreamReader;
+import com.att.nsa.cambria.resources.streamReaders.CambriaStreamReader;
+import com.att.nsa.cambria.resources.streamReaders.CambriaTextStreamReader;
import com.att.nsa.drumlin.service.standards.HttpStatusCodes;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources;
+package com.att.nsa.cambria.resources;
import java.io.IOException;
import java.io.OutputStream;
import org.json.JSONException;
import org.json.JSONObject;
import org.json.JSONTokener;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer.Message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Topic;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder.StreamWriter;
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.Consumer.Message;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.metabroker.Topic;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder.StreamWriter;
+import com.att.nsa.cambria.utils.Utils;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders;
+package com.att.nsa.cambria.resources.streamReaders;
import java.io.InputStream;
import org.json.JSONException;
import org.json.JSONObject;
import org.json.JSONTokener;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.LogDetails;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaEventSet.reader;
+
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.beans.LogDetails;
+import com.att.nsa.cambria.resources.CambriaEventSet.reader;
/**
*
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders;
+package com.att.nsa.cambria.resources.streamReaders;
import java.io.IOException;
import java.io.InputStream;
import javax.servlet.http.HttpServletResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.LogDetails;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaEventSet.reader;
-
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.beans.LogDetails;
+import com.att.nsa.cambria.resources.CambriaEventSet.reader;
import com.att.nsa.util.StreamTools;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders;
+package com.att.nsa.cambria.resources.streamReaders;
import java.io.IOException;
import java.io.InputStream;
import javax.servlet.http.HttpServletResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.LogDetails;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaEventSet.reader;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.beans.LogDetails;
+import com.att.nsa.cambria.resources.CambriaEventSet.reader;
/**
* Read an optionally chunked stream in the Cambria app format. This format
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.streamReaders;
+package com.att.nsa.cambria.resources.streamReaders;
import java.io.BufferedReader;
import java.io.IOException;
import javax.servlet.http.HttpServletResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.LogDetails;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaEventSet.reader;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.beans.LogDetails;
+import com.att.nsa.cambria.resources.CambriaEventSet.reader;
/**
* This stream reader just pulls single lines. It uses the default partition if provided. If
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security;
+package com.att.nsa.cambria.security;
import javax.servlet.http.HttpServletRequest;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.CambriaApiException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security;
+package com.att.nsa.cambria.security;
import java.util.Date;
import javax.servlet.http.HttpServletRequest;
import org.apache.http.HttpStatus;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPResponseCode;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
+
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.exception.DMaaPResponseCode;
+import com.att.nsa.cambria.exception.ErrorResponse;
+import com.att.nsa.cambria.utils.Utils;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security;
+package com.att.nsa.cambria.security;
import javax.servlet.http.HttpServletRequest;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-
+import com.att.nsa.cambria.beans.DMaaPContext;
import com.att.nsa.security.NsaApiKey;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security;
+package com.att.nsa.cambria.security;
import java.util.LinkedList;
import javax.servlet.http.HttpServletRequest;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.impl.DMaaPOriginalUebAuthenticator;
-
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.security.impl.DMaaPOriginalUebAuthenticator;
import com.att.nsa.security.NsaApiKey;
import com.att.nsa.security.NsaAuthenticator;
import com.att.nsa.security.authenticators.OriginalUebAuthenticator;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.impl;
+package com.att.nsa.cambria.security.impl;
import javax.servlet.http.HttpServletRequest;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticator;
+
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.security.DMaaPAuthenticator;
import com.att.nsa.security.NsaApiKey;
import com.att.nsa.security.authenticators.MechIdAuthenticator;
//import com.att.nsa.security.db.NsaApiDb;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.impl;
+package com.att.nsa.cambria.security.impl;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.servlet.http.HttpServletRequest;
-
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticator;
-
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.security.DMaaPAuthenticator;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.drumlin.till.data.sha1HmacSigner;
import com.att.nsa.security.NsaApiKey;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
import java.io.IOException;
import org.json.JSONException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.beans.DMaaPContext;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
import java.io.IOException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.ApiKeyBean;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-
+import com.att.nsa.cambria.beans.ApiKeyBean;
+import com.att.nsa.cambria.beans.DMaaPContext;
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.security.db.NsaApiDb.KeyExistsException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
import java.io.IOException;
import java.io.InputStream;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory.UnavailableException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker.TopicExistsException;
-
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.ConsumerFactory.UnavailableException;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
import java.io.IOException;
import java.io.InputStream;
import org.json.JSONException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory.UnavailableException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker.TopicExistsException;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.ConsumerFactory.UnavailableException;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
/**
* @author
*/
import java.io.IOException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.beans.DMaaPContext;
/**
*
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
import java.io.IOException;
import org.json.JSONException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.TopicBean;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker.TopicExistsException;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.beans.TopicBean;
+import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
import com.att.nsa.security.ReadWriteSecuredResource.AccessDeniedException;
import com.att.nsa.configs.ConfigDbException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
import java.io.IOException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.TransactionObj;
-
import com.att.aft.dme2.internal.jettison.json.JSONException;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.transaction.TransactionObj;
import com.att.nsa.configs.ConfigDbException;
/**
/**
*
*/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
+package com.att.nsa.cambria.service;
import java.io.IOException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-
+import com.att.nsa.cambria.beans.DMaaPContext;
import com.att.nsa.configs.ConfigDbException;
import kafka.common.TopicExistsException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.IOException;
import java.util.Collection;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticatorImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.AdminService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder;
import org.springframework.stereotype.Component;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.ConsumerFactory;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;
+import com.att.nsa.cambria.service.AdminService;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.limits.Blacklist;
import com.att.nsa.security.NsaApiKey;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.IOException;
import com.att.eelf.configuration.EELFManager;
import org.json.JSONArray;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.ApiKeyBean;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticatorImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.ApiKeysService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Emailer;
import org.springframework.stereotype.Service;
+//import com.att.nsa.apiServer.util.Emailer;
+import com.att.nsa.cambria.utils.Emailer;
+import com.att.nsa.cambria.beans.ApiKeyBean;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;
+import com.att.nsa.cambria.service.ApiKeysService;
+import com.att.nsa.cambria.utils.ConfigurationReader;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.drumlin.service.standards.HttpStatusCodes;
import com.att.nsa.security.NsaApiKey;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.util.Set;
import java.util.TreeSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.DMaaPTransactionFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.DMaaPTransactionObj;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.DMaaPTransactionObjDB;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.TransactionObj;
-
+import com.att.nsa.cambria.transaction.DMaaPTransactionFactory;
+import com.att.nsa.cambria.transaction.DMaaPTransactionObj;
+import com.att.nsa.cambria.transaction.DMaaPTransactionObjDB;
+import com.att.nsa.cambria.transaction.TransactionObj;
import com.att.nsa.configs.ConfigDb;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.configs.ConfigPath;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.IOException;
import java.io.InputStream;
import com.att.eelf.configuration.EELFManager;
import org.json.JSONObject;
import org.json.JSONTokener;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.MetricsSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory.UnavailableException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPCambriaLimiter;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.LogDetails;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPAccessDeniedException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPErrorMessages;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPResponseCode;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Topic;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker.TopicExistsException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaEventSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaOutboundEventStream;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAAFAuthenticator;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAAFAuthenticatorImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticatorImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.EventsService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.ConsumerFactory;
+import com.att.nsa.cambria.backends.ConsumerFactory.UnavailableException;
+import com.att.nsa.cambria.backends.MetricsSet;
+import com.att.nsa.cambria.backends.Publisher;
+import com.att.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.beans.DMaaPCambriaLimiter;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.beans.LogDetails;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.exception.DMaaPAccessDeniedException;
+import com.att.nsa.cambria.exception.DMaaPErrorMessages;
+import com.att.nsa.cambria.exception.DMaaPResponseCode;
+import com.att.nsa.cambria.exception.ErrorResponse;
+import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
+import com.att.nsa.cambria.metabroker.Topic;
+import com.att.nsa.cambria.resources.CambriaEventSet;
+import com.att.nsa.cambria.resources.CambriaOutboundEventStream;
+import com.att.nsa.cambria.security.DMaaPAAFAuthenticator;
+import com.att.nsa.cambria.security.DMaaPAAFAuthenticatorImpl;
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;
+import com.att.nsa.cambria.service.EventsService;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;
+import com.att.nsa.cambria.utils.Utils;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.drumlin.service.standards.MimeTypes;
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import org.json.JSONObject;
import org.json.JSONTokener;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Consumer;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.MetricsSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory.UnavailableException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher.message;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.LogDetails;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPAccessDeniedException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPErrorMessages;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPResponseCode;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Topic;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker.TopicExistsException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaEventSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.resources.CambriaOutboundEventStream;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAAFAuthenticator;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAAFAuthenticatorImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.MMService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.ConfigurationReader;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.Consumer;
+import com.att.nsa.cambria.backends.ConsumerFactory;
+import com.att.nsa.cambria.backends.ConsumerFactory.UnavailableException;
+import com.att.nsa.cambria.backends.Publisher.message;
+import com.att.nsa.cambria.backends.MetricsSet;
+import com.att.nsa.cambria.backends.Publisher;
+
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.beans.LogDetails;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.exception.DMaaPAccessDeniedException;
+import com.att.nsa.cambria.exception.DMaaPErrorMessages;
+import com.att.nsa.cambria.exception.DMaaPResponseCode;
+import com.att.nsa.cambria.exception.ErrorResponse;
+import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
+import com.att.nsa.cambria.metabroker.Topic;
+import com.att.nsa.cambria.resources.CambriaEventSet;
+import com.att.nsa.cambria.resources.CambriaOutboundEventStream;
+import com.att.nsa.cambria.security.DMaaPAAFAuthenticator;
+import com.att.nsa.cambria.security.DMaaPAAFAuthenticatorImpl;
+import com.att.nsa.cambria.service.MMService;
+import com.att.nsa.cambria.utils.ConfigurationReader;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;
+import com.att.nsa.cambria.utils.Utils;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.drumlin.service.standards.MimeTypes;
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.IOException;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.MetricsSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.MetricsService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder;
import org.springframework.stereotype.Component;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.backends.MetricsSet;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.service.MetricsService;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;
import com.att.nsa.metrics.CdmMeasuredItem;
/**
/**
*
*/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.IOException;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPKafkaMetaBroker;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.TopicBean;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPAccessDeniedException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPErrorMessages;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPResponseCode;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Topic;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker.TopicExistsException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAAFAuthenticator;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAAFAuthenticatorImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticatorImpl;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.TopicService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker;
+import com.att.nsa.cambria.beans.TopicBean;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.exception.DMaaPAccessDeniedException;
+import com.att.nsa.cambria.exception.DMaaPErrorMessages;
+import com.att.nsa.cambria.exception.DMaaPResponseCode;
+import com.att.nsa.cambria.exception.ErrorResponse;
+import com.att.nsa.cambria.metabroker.Broker;
+import com.att.nsa.cambria.metabroker.Broker.TopicExistsException;
+import com.att.nsa.cambria.metabroker.Topic;
+import com.att.nsa.cambria.security.DMaaPAAFAuthenticator;
+import com.att.nsa.cambria.security.DMaaPAAFAuthenticatorImpl;
+import com.att.nsa.cambria.security.DMaaPAuthenticatorImpl;
+import com.att.nsa.cambria.service.TopicService;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.security.NsaAcl;
import com.att.nsa.security.NsaApiKey;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.IOException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.TransactionService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.TransactionObj;
import org.springframework.stereotype.Service;
import com.att.aft.dme2.internal.jettison.json.JSONException;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.service.TransactionService;
+import com.att.nsa.cambria.transaction.TransactionObj;
import com.att.nsa.configs.ConfigDbException;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
import java.io.IOException;
import java.util.LinkedList;
import com.att.eelf.configuration.EELFManager;
import org.json.JSONArray;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPKafkaMetaBroker;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Topic;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.UIService;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPResponseBuilder;
import org.springframework.stereotype.Service;
+import com.att.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker;
+import com.att.nsa.cambria.metabroker.Topic;
+import com.att.nsa.cambria.service.UIService;
+import com.att.nsa.cambria.utils.DMaaPResponseBuilder;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.security.db.NsaApiDb;
import com.att.nsa.security.db.simple.NsaSimpleApiKey;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction;
+package com.att.nsa.cambria.transaction;
/**
*
* @author author
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction;
+package com.att.nsa.cambria.transaction;
import org.json.JSONObject;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction;
+package com.att.nsa.cambria.transaction;
import java.util.Set;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction;
+package com.att.nsa.cambria.transaction;
import org.json.JSONObject;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction;
+package com.att.nsa.cambria.transaction;
/**
* Created for transaction enable logging details, this is nothing but a bean
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.impl;
+package com.att.nsa.cambria.transaction.impl;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.DMaaPTransactionFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.DMaaPTransactionObj;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.transaction.TransactionObj;
+
+import com.att.nsa.cambria.transaction.DMaaPTransactionFactory;
+import com.att.nsa.cambria.transaction.DMaaPTransactionObj;
+import com.att.nsa.cambria.transaction.TransactionObj;
/**
* A factory for the simple Transaction implementation
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils;
+package com.att.nsa.cambria.utils;
import javax.servlet.ServletException;
import org.I0Itec.zkclient.ZkClient;
import org.apache.curator.framework.CuratorFramework;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.ConsumerFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.MetricsSet;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.Publisher;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka.KafkaConsumerCache.KafkaConsumerCacheException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory.MemoryConsumerFactory;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory.MemoryMetaBroker;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory.MemoryQueue;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory.MemoryQueuePublisher;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPCambriaLimiter;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPZkConfigDb;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.metabroker.Broker;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticator;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.impl.DMaaPOriginalUebAuthenticator;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Emailer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+//import com.att.nsa.apiServer.util.Emailer;
+import com.att.nsa.cambria.utils.Emailer;
+import com.att.nsa.cambria.backends.ConsumerFactory;
+import com.att.nsa.cambria.backends.MetricsSet;
+import com.att.nsa.cambria.backends.Publisher;
+import com.att.nsa.cambria.backends.kafka.KafkaConsumerCache.KafkaConsumerCacheException;
+import com.att.nsa.cambria.backends.memory.MemoryConsumerFactory;
+import com.att.nsa.cambria.backends.memory.MemoryMetaBroker;
+import com.att.nsa.cambria.backends.memory.MemoryQueue;
+import com.att.nsa.cambria.backends.memory.MemoryQueuePublisher;
+//import com.att.nsa.cambria.beans.DMaaPBlacklist;
+import com.att.nsa.cambria.beans.DMaaPCambriaLimiter;
+import com.att.nsa.cambria.beans.DMaaPZkConfigDb;
+import com.att.nsa.cambria.constants.CambriaConstants;
+import com.att.nsa.cambria.metabroker.Broker;
+import com.att.nsa.cambria.security.DMaaPAuthenticator;
+import com.att.nsa.cambria.security.impl.DMaaPOriginalUebAuthenticator;
import com.att.nsa.configs.ConfigDbException;
import com.att.nsa.configs.confimpl.MemConfigDb;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils;
+package com.att.nsa.cambria.utils;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-
+import com.att.nsa.cambria.constants.CambriaConstants;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils;
+package com.att.nsa.cambria.utils;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import com.att.eelf.configuration.EELFManager;
import org.json.JSONException;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
+
+import com.att.nsa.cambria.beans.DMaaPContext;
/**
* class is used to create response object which is given to user
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils;
+package com.att.nsa.cambria.utils;
import java.io.IOException;
import java.util.Properties;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMultipart;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
import com.att.ajsc.filemonitor.AJSCPropertiesMap;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+import com.att.nsa.cambria.constants.CambriaConstants;
import com.att.nsa.drumlin.till.nv.rrNvReadable;
/**
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils;
+package com.att.nsa.cambria.utils;
import java.io.File;
import java.net.MalformedURLException;
import java.util.HashMap;
import java.util.Map;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.constants.CambriaConstants;
-
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+
+import com.att.nsa.cambria.constants.CambriaConstants;
import com.att.nsa.drumlin.till.nv.impl.nvPropertiesFile;
import com.att.nsa.drumlin.till.nv.impl.nvReadableStack;
import com.att.nsa.drumlin.till.nv.impl.nvReadableTable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils;
+package com.att.nsa.cambria.utils;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import javax.servlet.http.HttpServletRequest;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPContext;
+import com.att.nsa.cambria.beans.DMaaPContext;
/**
* This is an utility class for various operations for formatting
* @author author
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.filter;
+package com.att.nsa.filter;
import java.io.IOException;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.json.JSONObject;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.CambriaApiException;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPErrorMessages;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.DMaaPResponseCode;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.exception.ErrorResponse;
import org.springframework.context.ApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;
+import com.att.nsa.cambria.CambriaApiException;
+import com.att.nsa.cambria.exception.DMaaPErrorMessages;
+import com.att.nsa.cambria.exception.DMaaPResponseCode;
+import com.att.nsa.cambria.exception.ErrorResponse;
+
/**
* Servlet Filter implementation class ContentLengthFilter
*/
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.filter;
+package com.att.nsa.filter;
public class DefaultLength {
date=2015-11-23T8:56:19-0700
# topic
-topicName=org.onap.dmaap.messagerouter.msgrtr.app.dmaap.mr.sharjeel
\ No newline at end of file
+topicName=com.att.app.dmaap.mr.sharjeel
\ No newline at end of file
#topics
subContextPathGetAllTopic=/topics
subContextPathGetOneTopic=/topics/
-SubContextPathGetPublisher=/topics/org.onap.dmaap.messagerouter.msgrtr.app.dmaap.mr.sharjeel/producers
-SubContextPathGetPermitPublisher=/topics/org.onap.dmaap.messagerouter.msgrtr.app.dmaap.mr.sharjeel/producers/rk229m@csp.att.com
-SubContextPathGetConsumer=/topics/org.onap.dmaap.messagerouter.msgrtr.app.dmaap.mr.sharjeel/consumers
+SubContextPathGetPublisher=/topics/com.att.app.dmaap.mr.sharjeel/producers
+SubContextPathGetPermitPublisher=/topics/com.att.app.dmaap.mr.sharjeel/producers/rk229m@csp.att.com
+SubContextPathGetConsumer=/topics/com.att.app.dmaap.mr.sharjeel/consumers
SubContextPathCreateTopic=/topics/create
-SubContextPathGetPermitConsumer=/topics/org.onap.dmaap.messagerouter.msgrtr.app.dmaap.mr.sharjeel/consumers/rk229m@att.com
-newTopic=org.onap.dmaap.messagerouter.msgrtr.dmaap.mr.junittestingtopic
+SubContextPathGetPermitConsumer=/topics/com.att.app.dmaap.mr.sharjeel/consumers/rk229m@att.com
+newTopic=com.att.dmaap.mr.junittestingtopic
topicDescription=new topic creation
partition=1
replication=1
txenabled=true
-deleteTopic=org.onap.dmaap.messagerouter.msgrtr.dmaap.mr.deleteTopic
+deleteTopic=com.att.dmaap.mr.deleteTopic
#Admin
Latitude =37.66
Longitude =-122.096839
Version =1.0.0
-ServiceName =org.onap.dmaap.messagerouter.msgrtr.acsi.saat.dt.dmaap.dev.demo1
+ServiceName =com.att.acsi.saat.dt.dmaap.dev.demo1
Environment =DEV
RouteOffer =LA
HostName =hltd436.hydc.sbc.com
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.endpoints
+package com.att.nsa.cambria.endpoints
#
# We need to deprecate the original non-versioned paths and use /v1/ for them.
JAVA=java
fi
-$JAVA -cp ${BASE_DIR}/etc${PATHSEP}${BASE_DIR}/lib/* org.onap.dmaap.messagerouter.messageservice.nsa.cambria.tools.ConfigTool $*
+$JAVA -cp ${BASE_DIR}/etc${PATHSEP}${BASE_DIR}/lib/* com.att.nsa.cambria.tools.ConfigTool $*
# SWM can only store a finite amount of packages in its repository, so this script deletes the oldest package.
# This script is run by Jenkins after the build is finished (post SWM upload).
-SWM_COMPONENT="org.onap.dmaap.messagerouter.msgrtr.nsa:msgrtr"
+SWM_COMPONENT="com.att.nsa:msgrtr"
SWM_PKGS=`/opt/app/swm/aftswmcli/bin/swmcli "component pkglist -c $SWM_COMPONENT -df -dh -dj -sui"`
SWM_PKGS_COUNT=`echo "$SWM_PKGS" | wc -l`
<bean id="drumlinRequestRouter"
class="com.att.nsa.drumlin.service.framework.routing.DrumlinRequestRouter" />
- <bean id="dMaaPMetricsSet" class="org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPMetricsSet">
+ <bean id="dMaaPMetricsSet" class="com.att.nsa.cambria.beans.DMaaPMetricsSet">
<constructor-arg ref="propertyReader" />
</bean>
- <bean id="dMaaPZkClient" class=" org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPZkClient">
+ <bean id="dMaaPZkClient" class=" com.att.nsa.cambria.beans.DMaaPZkClient">
<constructor-arg ref="propertyReader" />
</bean>
- <bean id="dMaaPZkConfigDb" class=" org.onap.dmaap.messagerouter.msgrt.nsa.cambria.beans.DMaaPZkConfigDb">
+ <bean id="dMaaPZkConfigDb" class=" com.att.nsa.cambria.beans.DMaaPZkConfigDb">
<constructor-arg ref="dMaaPZkClient" />
<constructor-arg ref="propertyReader" />
</bean>
- <bean id="kafkaPublisher" class=" org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.kafka.KafkaPublisher">
+ <bean id="kafkaPublisher" class=" com.att.nsa.cambria.backends.kafka.KafkaPublisher">
<constructor-arg ref="propertyReader" />
</bean>
- <bean id="dMaaPKafkaConsumerFactory" class=" org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPKafkaConsumerFactory">
+ <bean id="dMaaPKafkaConsumerFactory" class=" com.att.nsa.cambria.beans.DMaaPKafkaConsumerFactory">
<constructor-arg ref="propertyReader" />
<constructor-arg ref="dMaaPMetricsSet" />
<constructor-arg ref="curator" />
</bean>
- <bean id="curator" class="org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.DMaaPCuratorFactory"
+ <bean id="curator" class="com.att.nsa.cambria.utils.DMaaPCuratorFactory"
factory-method="getCurator">
<constructor-arg ref="propertyReader" />
</bean>
- <bean id="dMaaPKafkaMetaBroker" class=" org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPKafkaMetaBroker">
+ <bean id="dMaaPKafkaMetaBroker" class=" com.att.nsa.cambria.beans.DMaaPKafkaMetaBroker">
<constructor-arg ref="propertyReader" />
<constructor-arg ref="dMaaPZkClient" />
<constructor-arg ref="dMaaPZkConfigDb" />
</bean>
- <bean id="q" class=" org.onap.dmaap.messagerouter.msgrtr.com.att.nsa.cambria.backends.memory.MemoryQueue" />
+ <bean id="q" class=" com.att.nsa.cambria.backends.memory.MemoryQueue" />
- <bean id="mmb" class=" org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.backends.memory.MemoryMetaBroker">
+ <bean id="mmb" class=" com.att.nsa.cambria.backends.memory.MemoryMetaBroker">
<constructor-arg ref="q" />
<constructor-arg ref="dMaaPZkConfigDb" />
<!-- <constructor-arg ref="propertyReader" />-->
</bean>
- <bean id="dMaaPNsaApiDb" class="org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.beans.DMaaPNsaApiDb"
+ <bean id="dMaaPNsaApiDb" class="com.att.nsa.cambria.beans.DMaaPNsaApiDb"
factory-method="buildApiKeyDb">
<constructor-arg ref="propertyReader" />
<constructor-arg ref="dMaaPZkConfigDb" />
factory-method="buildTransactionDb"> <constructor-arg ref="propertyReader"
/> <constructor-arg ref="dMaaPZkConfigDb" /> </bean> -->
- <bean id="dMaaPAuthenticatorImpl" class="org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.security.DMaaPAuthenticatorImpl">
+ <bean id="dMaaPAuthenticatorImpl" class="com.att.nsa.cambria.security.DMaaPAuthenticatorImpl">
<constructor-arg ref="dMaaPNsaApiDb" />
</bean>
- <bean id="defLength" class="org.onap.dmaap.messagerouter.msgrtr.nsa.filter.DefaultLength">
+ <bean id="defLength" class="com.att.nsa.filter.DefaultLength">
<property name="defaultLength" value="${maxcontentlength}"></property>
</bean>
<param-value>/WEB-INF/spring-context.xml</param-value>
</context-param>
<listener>
- <listener-class>org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.listener.CambriaServletContextListener</listener-class>
+ <listener-class>com.att.nsa.cambria.listener.CambriaServletContextListener</listener-class>
</listener>
<filter>
<display-name>ContentLengthFilter</display-name>
<filter-name>ContentLengthFilter</filter-name>
- <filter-class>org.onap.dmaap.messagerouter.msgrtr.nsa.filter.ContentLengthFilter</filter-class>
+ <filter-class>com.att.nsa.filter.ContentLengthFilter</filter-class>
</filter>
<filter-mapping>
<filter-name>ContentLengthFilter</filter-name>
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import java.io.Serializable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import java.io.InputStream;
import java.util.Scanner;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import java.io.InputStream;
import java.util.Properties;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import java.io.InputStream;
import java.util.Properties;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import java.io.InputStream;
import java.util.Scanner;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import junit.framework.TestSuite;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import java.io.IOException;
import java.io.InputStream;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import org.junit.runner.JUnitCore;
import org.junit.runner.Result;
/**
*
*/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap;
+package com.att.mr.test.dmaap;
import java.io.Serializable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.io.Serializable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Properties;
import org.apache.log4j.Logger;
-import org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap.DmaapAdminTest;
import junit.framework.TestCase;
import com.att.aft.dme2.api.DME2Client;
import com.att.aft.dme2.api.DME2Exception;
+import com.att.mr.test.dmaap.DmaapAdminTest;
+//import com.ibm.disthub2.impl.client.PropSchema;
public class DME2AdminTest extends TestCase {
private static final Logger LOGGER = Logger.getLogger(DME2AdminTest.class);
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.net.URI;
import java.net.URISyntaxException;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Properties;
import org.apache.log4j.Logger;
-import org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap.DmaapAdminTest;
import junit.framework.TestCase;
import com.att.aft.dme2.api.DME2Client;
import com.att.aft.dme2.api.DME2Exception;
+import com.att.mr.test.dmaap.DmaapAdminTest;
public class DME2ConsumerFilterTest extends TestCase {
private static final Logger LOGGER = Logger.getLogger(DME2ConsumerFilterTest.class);
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Properties;
import org.apache.log4j.Logger;
-import org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap.DmaapAdminTest;
import junit.framework.TestCase;
import com.att.aft.dme2.api.DME2Client;
import com.att.aft.dme2.api.DME2Exception;
+import com.att.mr.test.dmaap.DmaapAdminTest;
public class DME2ConsumerTest extends TestCase {
private static final Logger LOGGER = Logger.getLogger(DME2ConsumerTest.class);
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Properties;
import org.apache.log4j.Logger;
-import org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap.DmaapAdminTest;
import junit.framework.TestCase;
import com.att.aft.dme2.api.DME2Client;
import com.att.aft.dme2.api.DME2Exception;
+import com.att.mr.test.dmaap.DmaapAdminTest;
public class DME2MetricsTest extends TestCase {
private static final Logger LOGGER = Logger.getLogger(DME2MetricsTest.class);
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Properties;
import org.apache.log4j.Logger;
-import org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap.DmaapAdminTest;
import junit.framework.TestCase;
import com.att.aft.dme2.api.DME2Client;
import com.att.aft.dme2.api.DME2Exception;
import com.att.aft.dme2.internal.jackson.map.ObjectMapper;
+import com.att.mr.test.dmaap.DmaapAdminTest;
public class DME2ProducerTest extends TestCase {
private static final Logger LOGGER = Logger.getLogger(DmaapAdminTest.class);
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.net.URI;
import java.net.URISyntaxException;
import javax.ws.rs.client.Entity;
import org.apache.log4j.Logger;
-import org.onap.dmaap.messagerouter.msgrtr.mr.test.dmaap.DmaapAdminTest;
import junit.framework.TestCase;
import com.att.aft.dme2.api.DME2Client;
import com.att.aft.dme2.api.DME2Exception;
import com.att.aft.dme2.internal.jackson.map.ObjectMapper;
+import com.att.mr.test.dmaap.DmaapAdminTest;
public class DME2TopicTest extends TestCase {
private String latitude;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import junit.framework.TestSuite;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.io.IOException;
import java.io.InputStream;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import org.junit.runner.JUnitCore;
import org.junit.runner.Result;
/**
*
*/
-package org.onap.dmaap.messagerouter.msgrtr.mr.test.dme2;
+package com.att.mr.test.dme2;
import java.io.Serializable;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria;
+package com.att.nsa.cambria;
import java.util.HashMap;
import java.util.Map;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria;
+package com.att.nsa.cambria;
import junit.framework.TestCase;
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*
*******************************************************************************/
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils;
+package com.att.nsa.cambria.utils;
import static org.junit.Assert.*;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
-import org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.utils.Utils;
public class UtilsTest {