Revert package name changes 11/9711/1
authorVarun Gudisena <vg411h@att.com>
Thu, 31 Aug 2017 15:52:33 +0000 (10:52 -0500)
committerVarun Gudisena <vg411h@att.com>
Thu, 31 Aug 2017 15:52:50 +0000 (10:52 -0500)
Reverted package name changes to avoid any potential issues. Renamed maven
    group id only.

Issue-id: DMAAP-74
Change-Id: Ic741b602ade60f108d940c0571a1d94b7be2abc2
Signed-off-by: Varun Gudisena <vg411h@att.com>
125 files changed:
pom.xml
src/main/java/com/att/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java with 94% similarity]
src/main/java/com/att/nsa/cambria/CambriaApiException.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaApiException.java with 94% similarity]
src/main/java/com/att/nsa/cambria/CambriaApiVersionInfo.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaApiVersionInfo.java with 98% similarity]
src/main/java/com/att/nsa/cambria/backends/Consumer.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/Consumer.java with 97% similarity]
src/main/java/com/att/nsa/cambria/backends/ConsumerFactory.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/ConsumerFactory.java with 97% similarity]
src/main/java/com/att/nsa/cambria/backends/MetricsSet.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/MetricsSet.java with 97% similarity]
src/main/java/com/att/nsa/cambria/backends/Publisher.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/Publisher.java with 95% similarity]
src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/kafka/KafkaConsumer.java with 97% similarity]
src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/kafka/KafkaConsumerCache.java with 98% similarity]
src/main/java/com/att/nsa/cambria/backends/kafka/KafkaPublisher.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/kafka/KafkaPublisher.java with 96% similarity]
src/main/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactory.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryConsumerFactory.java with 93% similarity]
src/main/java/com/att/nsa/cambria/backends/memory/MemoryMetaBroker.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryMetaBroker.java with 96% similarity]
src/main/java/com/att/nsa/cambria/backends/memory/MemoryQueue.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryQueue.java with 95% similarity]
src/main/java/com/att/nsa/cambria/backends/memory/MemoryQueuePublisher.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryQueuePublisher.java with 90% similarity]
src/main/java/com/att/nsa/cambria/backends/memory/MessageDropper.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MessageDropper.java with 92% similarity]
src/main/java/com/att/nsa/cambria/backends/memory/MessageLogger.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MessageLogger.java with 94% similarity]
src/main/java/com/att/nsa/cambria/beans/ApiKeyBean.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/ApiKeyBean.java with 97% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPCambriaLimiter.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPCambriaLimiter.java with 94% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPContext.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPContext.java with 95% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java with 94% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaMetaBroker.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPKafkaMetaBroker.java with 97% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPMetricsSet.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPMetricsSet.java with 96% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPNsaApiDb.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPNsaApiDb.java with 96% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPZkClient.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPZkClient.java with 92% similarity]
src/main/java/com/att/nsa/cambria/beans/DMaaPZkConfigDb.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPZkConfigDb.java with 90% similarity]
src/main/java/com/att/nsa/cambria/beans/LogDetails.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/LogDetails.java with 96% similarity]
src/main/java/com/att/nsa/cambria/beans/TopicBean.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/TopicBean.java with 98% similarity]
src/main/java/com/att/nsa/cambria/constants/CambriaConstants.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/constants/CambriaConstants.java with 96% similarity]
src/main/java/com/att/nsa/cambria/exception/DMaaPAccessDeniedException.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPAccessDeniedException.java with 91% similarity]
src/main/java/com/att/nsa/cambria/exception/DMaaPCambriaExceptionMapper.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPCambriaExceptionMapper.java with 95% similarity]
src/main/java/com/att/nsa/cambria/exception/DMaaPErrorMessages.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPErrorMessages.java with 98% similarity]
src/main/java/com/att/nsa/cambria/exception/DMaaPResponseCode.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPResponseCode.java with 97% similarity]
src/main/java/com/att/nsa/cambria/exception/DMaaPWebExceptionMapper.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPWebExceptionMapper.java with 98% similarity]
src/main/java/com/att/nsa/cambria/exception/ErrorResponse.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/ErrorResponse.java with 98% similarity]
src/main/java/com/att/nsa/cambria/listener/CambriaServletContextListener.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/listener/CambriaServletContextListener.java with 97% similarity]
src/main/java/com/att/nsa/cambria/listener/DME2EndPointLoader.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/listener/DME2EndPointLoader.java with 96% similarity]
src/main/java/com/att/nsa/cambria/metabroker/Broker.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metabroker/Broker.java with 94% similarity]
src/main/java/com/att/nsa/cambria/metabroker/Topic.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metabroker/Topic.java with 98% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaBatchingPublisher.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaBatchingPublisher.java with 96% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaClient.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaClient.java with 97% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaConsumer.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaConsumer.java with 96% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaPublisher.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaPublisher.java with 97% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaPublisherUtility.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaPublisherUtility.java with 98% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactory.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactory.java with 98% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/impl/CambriaBaseClient.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/CambriaBaseClient.java with 90% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/impl/Clock.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/Clock.java with 96% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaConsumerImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/DMaaPCambriaConsumerImpl.java with 94% similarity]
src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java with 96% similarity]
src/main/java/com/att/nsa/cambria/resources/CambriaEventSet.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/CambriaEventSet.java with 84% similarity]
src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/CambriaOutboundEventStream.java with 95% similarity]
src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaJsonStreamReader.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaJsonStreamReader.java with 91% similarity]
src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReader.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaRawStreamReader.java with 90% similarity]
src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaStreamReader.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaStreamReader.java with 93% similarity]
src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaTextStreamReader.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaTextStreamReader.java with 90% similarity]
src/main/java/com/att/nsa/cambria/security/DMaaPAAFAuthenticator.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAAFAuthenticator.java with 91% similarity]
src/main/java/com/att/nsa/cambria/security/DMaaPAAFAuthenticatorImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAAFAuthenticatorImpl.java with 85% similarity]
src/main/java/com/att/nsa/cambria/security/DMaaPAuthenticator.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAuthenticator.java with 94% similarity]
src/main/java/com/att/nsa/cambria/security/DMaaPAuthenticatorImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAuthenticatorImpl.java with 94% similarity]
src/main/java/com/att/nsa/cambria/security/impl/DMaaPMechIdAuthenticator.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/impl/DMaaPMechIdAuthenticator.java with 92% similarity]
src/main/java/com/att/nsa/cambria/security/impl/DMaaPOriginalUebAuthenticator.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/impl/DMaaPOriginalUebAuthenticator.java with 97% similarity]
src/main/java/com/att/nsa/cambria/service/AdminService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/AdminService.java with 95% similarity]
src/main/java/com/att/nsa/cambria/service/ApiKeysService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/ApiKeysService.java with 93% similarity]
src/main/java/com/att/nsa/cambria/service/EventsService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/EventsService.java with 86% similarity]
src/main/java/com/att/nsa/cambria/service/MMService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/MMService.java with 86% similarity]
src/main/java/com/att/nsa/cambria/service/MetricsService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/MetricsService.java with 88% similarity]
src/main/java/com/att/nsa/cambria/service/TopicService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/TopicService.java with 93% similarity]
src/main/java/com/att/nsa/cambria/service/TransactionService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/TransactionService.java with 89% similarity]
src/main/java/com/att/nsa/cambria/service/UIService.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/UIService.java with 95% similarity]
src/main/java/com/att/nsa/cambria/service/impl/AdminServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/AdminServiceImpl.java with 91% similarity]
src/main/java/com/att/nsa/cambria/service/impl/ApiKeysServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/ApiKeysServiceImpl.java with 94% similarity]
src/main/java/com/att/nsa/cambria/service/impl/BaseTransactionDbImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/BaseTransactionDbImpl.java with 91% similarity]
src/main/java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/EventsServiceImpl.java with 93% similarity]
src/main/java/com/att/nsa/cambria/service/impl/MMServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/MMServiceImpl.java with 91% similarity]
src/main/java/com/att/nsa/cambria/service/impl/MetricsServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/MetricsServiceImpl.java with 88% similarity]
src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/TopicServiceImpl.java with 94% similarity]
src/main/java/com/att/nsa/cambria/service/impl/TransactionServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/TransactionServiceImpl.java with 91% similarity]
src/main/java/com/att/nsa/cambria/service/impl/UIServiceImpl.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/UIServiceImpl.java with 93% similarity]
src/main/java/com/att/nsa/cambria/transaction/DMaaPTransactionFactory.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/DMaaPTransactionFactory.java with 95% similarity]
src/main/java/com/att/nsa/cambria/transaction/DMaaPTransactionObj.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/DMaaPTransactionObj.java with 97% similarity]
src/main/java/com/att/nsa/cambria/transaction/DMaaPTransactionObjDB.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/DMaaPTransactionObjDB.java with 97% similarity]
src/main/java/com/att/nsa/cambria/transaction/TransactionObj.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/TransactionObj.java with 98% similarity]
src/main/java/com/att/nsa/cambria/transaction/TrnRequest.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/TrnRequest.java with 97% similarity]
src/main/java/com/att/nsa/cambria/transaction/impl/DMaaPSimpleTransactionFactory.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/impl/DMaaPSimpleTransactionFactory.java with 85% similarity]
src/main/java/com/att/nsa/cambria/utils/ConfigurationReader.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/ConfigurationReader.java with 91% similarity]
src/main/java/com/att/nsa/cambria/utils/DMaaPCuratorFactory.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/DMaaPCuratorFactory.java with 95% similarity]
src/main/java/com/att/nsa/cambria/utils/DMaaPResponseBuilder.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/DMaaPResponseBuilder.java with 98% similarity]
src/main/java/com/att/nsa/cambria/utils/Emailer.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/Emailer.java with 97% similarity]
src/main/java/com/att/nsa/cambria/utils/PropertyReader.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/PropertyReader.java with 96% similarity]
src/main/java/com/att/nsa/cambria/utils/Utils.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/Utils.java with 96% similarity]
src/main/java/com/att/nsa/filter/ContentLengthFilter.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/filter/ContentLengthFilter.java with 93% similarity]
src/main/java/com/att/nsa/filter/DefaultLength.java [moved from src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/filter/DefaultLength.java with 96% similarity]
src/main/resources/DMaaPUrl.properties
src/main/resources/dme2testcase.properties
src/main/resources/endpoint.properties
src/main/resources/routes.conf
src/main/scripts/cambriaTool.sh
src/main/scripts/swmpkgclean.sh
src/main/webapp/WEB-INF/spring-context.xml
src/main/webapp/WEB-INF/web.xml
src/test/java/com/att/mr/test/dmaap/ApiKeyBean.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/ApiKeyBean.java with 97% similarity]
src/test/java/com/att/mr/test/dmaap/DMaapPubSubTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DMaapPubSubTest.java with 98% similarity]
src/test/java/com/att/mr/test/dmaap/DMaapTopicTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DMaapTopicTest.java with 99% similarity]
src/test/java/com/att/mr/test/dmaap/DmaapAdminTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DmaapAdminTest.java with 97% similarity]
src/test/java/com/att/mr/test/dmaap/DmaapApiKeyTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DmaapApiKeyTest.java with 98% similarity]
src/test/java/com/att/mr/test/dmaap/DmaapMetricsTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DmaapMetricsTest.java with 98% similarity]
src/test/java/com/att/mr/test/dmaap/JUnitTestSuite.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/JUnitTestSuite.java with 96% similarity]
src/test/java/com/att/mr/test/dmaap/LoadPropertyFile.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/LoadPropertyFile.java with 97% similarity]
src/test/java/com/att/mr/test/dmaap/TestRunner.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/TestRunner.java with 96% similarity]
src/test/java/com/att/mr/test/dmaap/TopicBean.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/TopicBean.java with 97% similarity]
src/test/java/com/att/mr/test/dme2/ApiKeyBean.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/ApiKeyBean.java with 97% similarity]
src/test/java/com/att/mr/test/dme2/DME2AdminTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2AdminTest.java with 97% similarity]
src/test/java/com/att/mr/test/dme2/DME2ApiKeyTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ApiKeyTest.java with 99% similarity]
src/test/java/com/att/mr/test/dme2/DME2ConsumerFilterTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ConsumerFilterTest.java with 96% similarity]
src/test/java/com/att/mr/test/dme2/DME2ConsumerTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ConsumerTest.java with 96% similarity]
src/test/java/com/att/mr/test/dme2/DME2MetricsTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2MetricsTest.java with 97% similarity]
src/test/java/com/att/mr/test/dme2/DME2ProducerTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ProducerTest.java with 96% similarity]
src/test/java/com/att/mr/test/dme2/DME2TopicTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2TopicTest.java with 99% similarity]
src/test/java/com/att/mr/test/dme2/JUnitTestSuite.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/JUnitTestSuite.java with 97% similarity]
src/test/java/com/att/mr/test/dme2/LoadPropertyFile.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/LoadPropertyFile.java with 97% similarity]
src/test/java/com/att/mr/test/dme2/TestRunner.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/TestRunner.java with 96% similarity]
src/test/java/com/att/mr/test/dme2/TopicBeanDME2.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/TopicBeanDME2.java with 97% similarity]
src/test/java/com/att/nsa/cambria/CambriaApiTestCase.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaApiTestCase.java with 97% similarity]
src/test/java/com/att/nsa/cambria/CambriaRateLimiterTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaRateLimiterTest.java with 97% similarity]
src/test/java/com/att/nsa/cambria/utils/UtilsTest.java [moved from src/test/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/UtilsTest.java with 93% similarity]

diff --git a/pom.xml b/pom.xml
index a26425e..644c9a0 100644 (file)
--- a/pom.xml
+++ b/pom.xml
        <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 -->
@@ -53,7 +54,7 @@
 
         <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>
 
@@ -19,7 +19,7 @@
  *  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;
@@ -34,13 +34,12 @@ import org.json.JSONException;
 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
 {
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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.
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -38,6 +36,8 @@ import kafka.message.MessageAndMetadata;
 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.
@@ -19,7 +19,7 @@
  *  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;
@@ -46,16 +46,15 @@ import org.apache.curator.utils.ZKPaths;
 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;
 
 /**
@@ -19,7 +19,7 @@
  *  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;
@@ -33,15 +33,14 @@ import kafka.producer.KeyedMessage;
 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
@@ -19,7 +19,7 @@
  *  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;
@@ -27,9 +27,8 @@ import java.util.List;
 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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -28,7 +28,7 @@ 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;
 
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -30,14 +30,14 @@ 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -28,7 +28,7 @@ import javax.servlet.http.HttpServletRequest;
 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
@@ -19,7 +19,7 @@
  *  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;
@@ -31,21 +31,20 @@ import java.util.concurrent.TimeUnit;
 
 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -35,12 +35,12 @@ import com.att.eelf.configuration.EELFManager;
 
 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -28,10 +28,9 @@ import java.util.concurrent.Executors;
 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
  *  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.
@@ -19,9 +19,9 @@
  *  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{
        
@@ -19,7 +19,7 @@
  *  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;
@@ -29,9 +29,11 @@ import javax.ws.rs.ext.Provider;
 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 
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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 
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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/>
@@ -19,7 +19,7 @@
  *  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;
@@ -29,21 +29,20 @@ import java.util.concurrent.TimeUnit;
 
 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
        {
@@ -19,7 +19,7 @@
  *  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;
 
 /**
  * 
@@ -19,7 +19,7 @@
  *  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;
@@ -34,10 +34,10 @@ import jline.internal.Log;
 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;
 
 /**
  * 
@@ -45,7 +45,7 @@ import com.att.nsa.apiClient.http.HttpObjectNotFoundException;
  *
  */
 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -39,10 +39,9 @@ import javax.ws.rs.client.Entity;
 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;
 
 /**
  * 
@@ -53,7 +52,7 @@ import com.att.ajsc.filemonitor.AJSCPropertiesMap;
  *
  */
 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
@@ -19,7 +19,7 @@
  *  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;
@@ -27,14 +27,13 @@ import java.util.zip.GZIPInputStream;
 
 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;
 
 /**
@@ -19,7 +19,7 @@
  *  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;
@@ -33,16 +33,16 @@ import com.att.eelf.configuration.EELFManager;
 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;
 
 
 /**
@@ -19,7 +19,7 @@
  *  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;
 
@@ -28,10 +28,11 @@ import javax.servlet.http.HttpServletResponse;
 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
@@ -19,7 +19,7 @@
  *  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;
@@ -28,10 +28,10 @@ import java.io.InputStreamReader;
 
 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;
@@ -19,7 +19,7 @@
  *  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 
@@ -27,8 +27,8 @@ package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service;
  */
 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -28,16 +28,16 @@ import java.util.Set;
 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;
@@ -19,7 +19,7 @@
  *  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;
 
@@ -27,16 +27,17 @@ import com.att.eelf.configuration.EELFLogger;
 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -37,35 +37,35 @@ import com.att.eelf.configuration.EELFLogger;
 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -39,35 +39,36 @@ 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.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;
 
 /**
@@ -22,7 +22,7 @@
 /**
  * 
  */
-package org.onap.dmaap.messagerouter.msgrtr.nsa.cambria.service.impl;
+package com.att.nsa.cambria.service.impl;
 
 import java.io.IOException;
 
@@ -32,27 +32,27 @@ import com.att.eelf.configuration.EELFManager;
 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;
 
 /**
@@ -19,7 +19,7 @@
  *  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;
@@ -31,13 +31,13 @@ import com.att.eelf.configuration.EELFLogger;
 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;
@@ -19,7 +19,7 @@
  *  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
@@ -19,7 +19,7 @@
  *  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;
 /**
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
 
 /**
@@ -19,7 +19,7 @@
  *  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;
@@ -33,7 +33,8 @@ import com.att.eelf.configuration.EELFLogger;
 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
@@ -19,7 +19,7 @@
  *  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;
@@ -37,14 +37,13 @@ import javax.mail.internet.MimeBodyPart;
 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;
 
 /**
@@ -19,7 +19,7 @@
  *  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;
@@ -27,10 +27,10 @@ import java.net.URL;
 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;
@@ -19,7 +19,7 @@
  *  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;
@@ -30,7 +30,7 @@ import java.util.List;
 
 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
@@ -19,7 +19,7 @@
  *  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;
 
@@ -35,13 +35,14 @@ import org.apache.http.HttpStatus;
 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
  */
@@ -19,7 +19,7 @@
  *  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 {
index 8c90912..a0cf9ab 100644 (file)
@@ -36,4 +36,4 @@ url=http://hltd436.hydc.sbc.com:8080/DMaaP/dmaaprest/
 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
index 6f358a3..ad38c43 100644 (file)
@@ -39,17 +39,17 @@ filterType=filter={"class":"Equals", "field":"email", "value":"ai039a@att.com"}
 #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
index f1ab131..34e222f 100644 (file)
@@ -22,7 +22,7 @@
 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
index 14c4f56..ccaa94d 100644 (file)
@@ -1,4 +1,4 @@
-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.
index 175a19c..a9d6e15 100644 (file)
@@ -52,4 +52,4 @@ else
     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 $*
index 5f8699f..7e6bc51 100644 (file)
@@ -24,7 +24,7 @@
 # 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`
index d7f128e..5e2e985 100644 (file)
        <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>
 
index c3e07b5..46d7b45 100644 (file)
     <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>
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
 
 
 
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -27,12 +27,13 @@ import java.util.HashMap;
 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);
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
@@ -28,12 +28,12 @@ import java.util.HashMap;
 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);
@@ -19,7 +19,7 @@
  *  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;
@@ -27,12 +27,12 @@ import java.util.HashMap;
 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);
@@ -19,7 +19,7 @@
  *  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;
@@ -27,12 +27,12 @@ import java.util.HashMap;
 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);
@@ -19,7 +19,7 @@
  *  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;
@@ -27,13 +27,13 @@ import java.util.HashMap;
 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);
@@ -19,7 +19,7 @@
  *  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;
@@ -29,13 +29,13 @@ import java.util.Properties;
 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;
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
@@ -19,7 +19,7 @@
  *  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;
 
@@ -19,7 +19,7 @@
  *  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.*;
 
@@ -29,7 +29,6 @@ import java.util.Date;
 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 {