gerrit.onap Code Review - dmaap/messagerouter/msgrtr.git/commit

Code Review / dmaap / messagerouter / msgrtr.git / commit

author	sunil unnava <su622b@att.com>
	Tue, 14 Aug 2018 13:34:46 +0000 (09:34 -0400)
committer	sunil unnava <su622b@att.com>
	Tue, 14 Aug 2018 13:39:23 +0000 (09:39 -0400)
commit	b32effcaf5684d5e2f338a4537b71a2375c534e5
tree	e1b80407f414509ffcc766b987ec6a95f7254b4e	tree \| snapshot
parent	0823cb186012c8e6b7de3d979dfabb9f838da7c2	commit \| diff

update the testcases after the kafka 11 changes

Issue-ID: DMAAP-526
Change-Id: I477a8ee05fb3cdd76af726b6ca0d1a69aa9eef93
Signed-off-by: sunil unnava <su622b@att.com>

209 files changed:

.project		diff \| blob \| history
pom.xml		diff \| blob \| history
src/main/java/com/att/dmf/mr/CambriaApiException.java	[moved from src/main/java/com/att/nsa/cambria/CambriaApiException.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/CambriaApiVersionInfo.java	[moved from src/main/java/com/att/nsa/cambria/CambriaApiVersionInfo.java with 98% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/Consumer.java	[moved from src/main/java/com/att/nsa/cambria/backends/Consumer.java with 88% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/ConsumerFactory.java	[moved from src/main/java/com/att/nsa/cambria/backends/ConsumerFactory.java with 83% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/MetricsSet.java	[moved from src/main/java/com/att/nsa/cambria/backends/MetricsSet.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/Publisher.java	[moved from src/main/java/com/att/nsa/cambria/backends/Publisher.java with 84% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/kafka/Kafka011Consumer.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/backends/kafka/Kafka011ConsumerUtil.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/backends/kafka/KafkaConsumer.txt	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/backends/kafka/KafkaConsumerCache.java	[moved from src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java with 64% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/kafka/KafkaLiveLockAvoider2.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/backends/kafka/KafkaPublisher.java	[moved from src/main/java/com/att/nsa/cambria/backends/kafka/KafkaPublisher.java with 61% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/kafka/LiveLockAvoidance.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/backends/kafka/LockInstructionWatcher.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/backends/memory/MemoryConsumerFactory.java	[moved from src/main/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactory.java with 82% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/memory/MemoryMetaBroker.java	[moved from src/main/java/com/att/nsa/cambria/backends/memory/MemoryMetaBroker.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/memory/MemoryQueue.java	[moved from src/main/java/com/att/nsa/cambria/backends/memory/MemoryQueue.java with 95% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/memory/MemoryQueuePublisher.java	[moved from src/main/java/com/att/nsa/cambria/backends/memory/MemoryQueuePublisher.java with 83% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/backends/memory/MessageLogger.java	[moved from src/main/java/com/att/nsa/cambria/backends/memory/MessageLogger.java with 85% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/ApiKeyBean.java	[moved from src/main/java/com/att/nsa/cambria/beans/ApiKeyBean.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/DMaaPCambriaLimiter.java	[moved from src/main/java/com/att/nsa/cambria/beans/DMaaPCambriaLimiter.java with 63% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/DMaaPContext.java	[moved from src/main/java/com/att/nsa/cambria/beans/DMaaPContext.java with 95% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/DMaaPKafkaConsumerFactory.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/beans/DMaaPKafkaMetaBroker.java	[moved from src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaMetaBroker.java with 71% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/DMaaPMetricsSet.java	[moved from src/main/java/com/att/nsa/cambria/beans/DMaaPMetricsSet.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/DMaaPNsaApiDb.java	[moved from src/main/java/com/att/nsa/cambria/beans/DMaaPNsaApiDb.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/DMaaPZkClient.java	[moved from src/main/java/com/att/nsa/cambria/beans/DMaaPZkClient.java with 94% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/DMaaPZkConfigDb.java	[moved from src/main/java/com/att/nsa/cambria/beans/DMaaPZkConfigDb.java with 93% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/LogDetails.java	[moved from src/main/java/com/att/nsa/cambria/beans/LogDetails.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/beans/TopicBean.java	[moved from src/main/java/com/att/nsa/cambria/beans/TopicBean.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/constants/CambriaConstants.java	[moved from src/main/java/com/att/nsa/cambria/constants/CambriaConstants.java with 93% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/exception/DMaaPAccessDeniedException.java	[moved from src/main/java/com/att/nsa/cambria/exception/DMaaPAccessDeniedException.java with 94% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/exception/DMaaPCambriaExceptionMapper.java	[moved from src/main/java/com/att/nsa/cambria/exception/DMaaPCambriaExceptionMapper.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/exception/DMaaPErrorMessages.java	[moved from src/main/java/com/att/nsa/cambria/exception/DMaaPErrorMessages.java with 84% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/exception/DMaaPResponseCode.java	[moved from src/main/java/com/att/nsa/cambria/exception/DMaaPResponseCode.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/exception/DMaaPWebExceptionMapper.java	[moved from src/main/java/com/att/nsa/cambria/exception/DMaaPWebExceptionMapper.java with 98% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/exception/ErrorResponse.java	[moved from src/main/java/com/att/nsa/cambria/exception/ErrorResponse.java with 98% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/listener/CambriaServletContextListener.java	[moved from src/main/java/com/att/nsa/cambria/listener/CambriaServletContextListener.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/listener/DME2EndPointLoader.java	[moved from src/main/java/com/att/nsa/cambria/listener/DME2EndPointLoader.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metabroker/Broker.java	[moved from src/main/java/com/att/nsa/cambria/metabroker/Broker.java with 92% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metabroker/Broker1.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/metabroker/Topic.java	[moved from src/main/java/com/att/nsa/cambria/metabroker/Topic.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/CambriaBatchingPublisher.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaBatchingPublisher.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/CambriaClient.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaClient.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/CambriaConsumer.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaConsumer.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/CambriaPublisher.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaPublisher.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/CambriaPublisherUtility.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/CambriaPublisherUtility.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/DMaaPCambriaClientFactory.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactory.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/impl/CambriaBaseClient.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/impl/CambriaBaseClient.java with 83% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/impl/Clock.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/impl/Clock.java with 90% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/impl/DMaaPCambriaConsumerImpl.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaConsumerImpl.java with 94% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java	[moved from src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java with 93% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/resources/CambriaEventSet.java	[moved from src/main/java/com/att/nsa/cambria/resources/CambriaEventSet.java with 87% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/resources/CambriaOutboundEventStream.java	[moved from src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java with 50% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/resources/streamReaders/CambriaJsonStreamReader.java	[moved from src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaJsonStreamReader.java with 89% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/resources/streamReaders/CambriaRawStreamReader.java	[moved from src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReader.java with 92% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/resources/streamReaders/CambriaStreamReader.java	[moved from src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaStreamReader.java with 95% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/resources/streamReaders/CambriaTextStreamReader.java	[moved from src/main/java/com/att/nsa/cambria/resources/streamReaders/CambriaTextStreamReader.java with 89% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/security/DMaaPAAFAuthenticator.java	[moved from src/main/java/com/att/nsa/cambria/security/DMaaPAAFAuthenticator.java with 93% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/security/DMaaPAAFAuthenticatorImpl.java	[moved from src/main/java/com/att/nsa/cambria/security/DMaaPAAFAuthenticatorImpl.java with 61% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/security/DMaaPAuthenticator.java	[moved from src/main/java/com/att/nsa/cambria/security/DMaaPAuthenticator.java with 95% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/security/DMaaPAuthenticatorImpl.java	[moved from src/main/java/com/att/nsa/cambria/security/DMaaPAuthenticatorImpl.java with 90% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/security/impl/DMaaPMechIdAuthenticator.java	[moved from src/main/java/com/att/nsa/cambria/security/impl/DMaaPMechIdAuthenticator.java with 94% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/security/impl/DMaaPOriginalUebAuthenticator.java	[moved from src/main/java/com/att/nsa/cambria/security/impl/DMaaPOriginalUebAuthenticator.java with 98% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/AdminService.java	[moved from src/main/java/com/att/nsa/cambria/service/AdminService.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/ApiKeysService.java	[moved from src/main/java/com/att/nsa/cambria/service/ApiKeysService.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/EventsService.java	[moved from src/main/java/com/att/nsa/cambria/service/EventsService.java with 89% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/MMService.java	[moved from src/main/java/com/att/nsa/cambria/service/MMService.java with 87% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/MetricsService.java	[moved from src/main/java/com/att/nsa/cambria/service/MetricsService.java with 90% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/TopicService.java	[moved from src/main/java/com/att/nsa/cambria/service/TopicService.java with 95% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/TransactionService.java	[moved from src/main/java/com/att/nsa/cambria/service/TransactionService.java with 92% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/UIService.java	[moved from src/main/java/com/att/nsa/cambria/service/UIService.java with 93% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/AdminServiceImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/AdminServiceImpl.java with 90% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/ApiKeysServiceImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/ApiKeysServiceImpl.java with 94% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/BaseTransactionDbImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/BaseTransactionDbImpl.java with 93% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/EventsServiceImpl.java	[new file with mode: 0644]	blob
src/main/java/com/att/dmf/mr/service/impl/MMServiceImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/MMServiceImpl.java with 90% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/MetricsServiceImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/MetricsServiceImpl.java with 91% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/TopicServiceImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/TopicServiceImpl.java with 57% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/TransactionServiceImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/TransactionServiceImpl.java with 94% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/service/impl/UIServiceImpl.java	[moved from src/main/java/com/att/nsa/cambria/service/impl/UIServiceImpl.java with 93% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/transaction/DMaaPTransactionFactory.java	[moved from src/main/java/com/att/nsa/cambria/transaction/DMaaPTransactionFactory.java with 95% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/transaction/DMaaPTransactionObj.java	[moved from src/main/java/com/att/nsa/cambria/transaction/DMaaPTransactionObj.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/transaction/DMaaPTransactionObjDB.java	[moved from src/main/java/com/att/nsa/cambria/transaction/DMaaPTransactionObjDB.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/transaction/TransactionObj.java	[moved from src/main/java/com/att/nsa/cambria/transaction/TransactionObj.java with 98% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/transaction/TrnRequest.java	[moved from src/main/java/com/att/nsa/cambria/transaction/TrnRequest.java with 98% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/transaction/impl/DMaaPSimpleTransactionFactory.java	[moved from src/main/java/com/att/nsa/cambria/transaction/impl/DMaaPSimpleTransactionFactory.java with 89% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/utils/ConfigurationReader.java	[moved from src/main/java/com/att/nsa/cambria/utils/ConfigurationReader.java with 89% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/utils/DMaaPCuratorFactory.java	[moved from src/main/java/com/att/nsa/cambria/utils/DMaaPCuratorFactory.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/utils/DMaaPResponseBuilder.java	[moved from src/main/java/com/att/nsa/cambria/utils/DMaaPResponseBuilder.java with 96% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/utils/Emailer.java	[moved from src/main/java/com/att/nsa/cambria/utils/Emailer.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/utils/PropertyReader.java	[moved from src/main/java/com/att/nsa/cambria/utils/PropertyReader.java with 91% similarity]	diff \| blob \| history
src/main/java/com/att/dmf/mr/utils/Utils.java	[moved from src/main/java/com/att/nsa/cambria/utils/Utils.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/mr/apiServer/metrics/cambria/DMaaPMetricsSender.java	[moved from src/main/java/com/att/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java with 90% similarity]	diff \| blob \| history
src/main/java/com/att/mr/filter/ContentLengthFilter.java	[moved from src/main/java/com/att/nsa/filter/ContentLengthFilter.java with 94% similarity]	diff \| blob \| history
src/main/java/com/att/mr/filter/DefaultLength.java	[moved from src/main/java/com/att/nsa/filter/DefaultLength.java with 97% similarity]	diff \| blob \| history
src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java	[deleted file]	blob \| history
src/main/java/com/att/nsa/cambria/backends/memory/MessageDropper.java	[deleted file]	blob \| history
src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java	[deleted file]	blob \| history
src/main/java/com/att/nsa/cambria/beans/ZkClientFactory.java	[deleted file]	blob \| history
src/main/java/com/att/nsa/cambria/service/impl/EventsServiceImpl.java	[deleted file]	blob \| history
src/test/java/com/att/nsa/apiServer/metrics/cambria/DMaaPMetricsSenderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/CambriaApiExceptionTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/CambriaApiVersionInfoTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/kafka/JUnitTestSuite.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCacheTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerTest.java	[deleted file]	blob \| history
src/test/java/com/att/nsa/cambria/backends/kafka/KafkaPublisherTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/kafka/MetricsSetImpl.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/memory/JUnitTestSuite.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/memory/MemoryConsumerFactoryTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/memory/MemoryMetaBrokerTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueuePublisherTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/memory/MemoryQueueTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/backends/memory/MessageDropperTest.java	[deleted file]	blob \| history
src/test/java/com/att/nsa/cambria/backends/memory/MessageLoggerTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/ApiKeyBeanTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/ApiKeyBeanTest2.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/ApiKeyBeanTest3.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/ApiKeyBeanTest4.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/ApiKeyBeanTest5.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/ApiKeyBeanTest6.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPCambriaLimiterTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPContextTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPContextTest2.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPContextTest3.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPContextTest4.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPContextTest5.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPContextTest6.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/DMaaPKafkaMetaBrokerTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/JUnitTestSuite.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest10.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest11.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest12.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest13.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest14.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest15.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest16.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest17.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest18.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest2.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest3.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest4.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest5.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest6.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest7.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest8.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/LogDetailsTest9.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest10.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest2.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest3.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest4.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest5.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest6.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest7.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest8.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/beans/TopicBeanTest9.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/embed/EmbedConfigurationReader.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/exception/DMaaPCambriaExceptionMapperTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/exception/DMaaPErrorMessagesTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/exception/DMaaPWebExceptionMapperTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/exception/ErrorResponseTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/listener/CambriaServletContextListenerTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/listener/DME2EndPointLoaderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metabroker/BrokerImpl.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metabroker/BrokerImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metabroker/TopicImplem.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metrics/publisher/CambriaPublisherUtilityTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactoryTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metrics/publisher/impl/CambriaBaseClientTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metrics/publisher/impl/ClockTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaConsumerImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisherTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/resources/CambriaEventSetTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/resources/CambriaOutboundEventStreamTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaJsonStreamReaderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaRawStreamReaderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaStreamReaderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/resources/streamReaders/CambriaTextStreamReaderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/security/DMaaPAAFAuthenticatorImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/security/DMaaPAuthenticatorImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/security/impl/DMaaPMechIdAuthenticatorTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/security/impl/DMaaPOriginalUebAuthenticatorTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/AdminServiceImplemTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/ApiKeysServiceImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/BaseTransactionDbImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/EventsServiceImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/JUnitTestSuite.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/MMServiceImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/MessageTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/MetricsServiceImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/ShowConsumerCacheTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/TopicServiceImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/TransactionServiceImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/service/impl/UIServiceImplTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/transaction/TransactionObjTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/transaction/TrnRequestTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/transaction/impl/DMaaPSimpleTransactionFactoryTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/utils/ConfigurationReaderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/utils/DMaaPCuratorFactoryTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/utils/DMaaPResponseBuilderTest.java		diff \| blob \| history
src/test/java/com/att/nsa/cambria/utils/UtilsTest.java		diff \| blob \| history
src/test/java/com/att/nsa/filter/ContentLengthFilterTest.java		diff \| blob \| history
src/test/java/com/att/nsa/filter/DefaultLengthTest.java		diff \| blob \| history
version.properties		diff \| blob \| history

Provides REST API for messaging. It is built on top of Apache Kafka. ( READ ONLY - Repository has been moved.)

RSS Atom