Code Review / dmaap / messagerouter / msgrtr.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: d53cd5d) | patch
Add Initial Code Import 29/9529/1
authorVarun Gudisena <vg411h@att.com>
Wed, 30 Aug 2017 21:00:10 +0000 (16:00 -0500)
committerVarun Gudisena <vg411h@att.com>
Wed, 30 Aug 2017 21:00:18 +0000 (16:00 -0500)
commitca63da6e0cb7fb63e231343d0b52a40036f6b6aa
tree1f03578a5badef32c983b1ebcab9df447b30e214tree | snapshot
parentd53cd5dba6a7a74bba79d8e4bca5c60d0c9779b8commit | diff
Add Initial Code Import

Added initial code for DMaaP Message Router Component

Issue-id: DMAAP-76
Change-Id: Ica6f265ea4f2901cf47191f21b4448514ea7c8d4
Signed-off-by: Varun Gudisena <vg411h@att.com>
166 files changed:
.gitignore [new file with mode: 0644] blob
LICENSE [new file with mode: 0644] blob
etc/cambriaApi.properties [new file with mode: 0644] blob
etc/cambriaApi_template.properties [new file with mode: 0644] blob
etc/log4j.xml [new file with mode: 0644] blob
etc/log4j_template.xml [new file with mode: 0644] blob
etc/logstash_cambria_template.conf [new file with mode: 0644] blob
notes/capacityMath.xlsx [new file with mode: 0644] blob
notes/keys.txt [new file with mode: 0644] blob
notes/systems.xlsx [new file with mode: 0644] blob
notes/users.csv [new file with mode: 0644] blob
pom.xml [new file with mode: 0644] blob
src/assembly/dep.xml [new file with mode: 0644] blob
src/main/config/fixme.txt [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaApiException.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaApiVersionInfo.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/Consumer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/ConsumerFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/MetricsSet.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/Publisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/kafka/KafkaConsumer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/kafka/KafkaConsumerCache.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/kafka/KafkaPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryConsumerFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryMetaBroker.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryQueue.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MemoryQueuePublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MessageDropper.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/backends/memory/MessageLogger.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/ApiKeyBean.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPCambriaLimiter.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPContext.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPKafkaMetaBroker.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPMetricsSet.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPNsaApiDb.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPZkClient.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/DMaaPZkConfigDb.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/LogDetails.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/beans/TopicBean.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/constants/CambriaConstants.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPAccessDeniedException.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPCambriaExceptionMapper.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPErrorMessages.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPResponseCode.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/DMaaPWebExceptionMapper.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/exception/ErrorResponse.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/listener/CambriaServletContextListener.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/listener/DME2EndPointLoader.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metabroker/Broker.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metabroker/Topic.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaBatchingPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaClient.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaConsumer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/CambriaPublisherUtility.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/DMaaPCambriaClientFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/CambriaBaseClient.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/Clock.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/DMaaPCambriaConsumerImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/CambriaEventSet.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/CambriaOutboundEventStream.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaJsonStreamReader.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaRawStreamReader.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaStreamReader.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/resources/streamReaders/CambriaTextStreamReader.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAAFAuthenticator.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAAFAuthenticatorImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAuthenticator.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/DMaaPAuthenticatorImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/impl/DMaaPMechIdAuthenticator.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/security/impl/DMaaPOriginalUebAuthenticator.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/AdminService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/ApiKeysService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/EventsService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/MMService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/MetricsService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/TopicService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/TransactionService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/UIService.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/AdminServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/ApiKeysServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/BaseTransactionDbImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/EventsServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/MMServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/MetricsServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/TopicServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/TransactionServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/service/impl/UIServiceImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/DMaaPTransactionFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/DMaaPTransactionObj.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/DMaaPTransactionObjDB.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/TransactionObj.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/TrnRequest.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/transaction/impl/DMaaPSimpleTransactionFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/ConfigurationReader.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/DMaaPCuratorFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/DMaaPResponseBuilder.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/Emailer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/PropertyReader.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/Utils.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/filter/ContentLengthFilter.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/msgrtr/nsa/filter/DefaultLength.java [new file with mode: 0644] blob
src/main/resources/DMaaPUrl.properties [new file with mode: 0644] blob
src/main/resources/cambriaApiVersion.properties [new file with mode: 0644] blob
src/main/resources/dme2testcase.properties [new file with mode: 0644] blob
src/main/resources/endpoint.properties [new file with mode: 0644] blob
src/main/resources/images/attLogo.gif [new file with mode: 0644] blob
src/main/resources/images/att_vt_1cp_grd_rev.gif [new file with mode: 0644] blob
src/main/resources/routes.conf [new file with mode: 0644] blob
src/main/resources/templates/hello.html [new file with mode: 0644] blob
src/main/scripts/cambria.sh [new file with mode: 0644] blob
src/main/scripts/cambriaJsonPublisher.sh [new file with mode: 0644] blob
src/main/scripts/cambriaMonitor.sh [new file with mode: 0644] blob
src/main/scripts/cambriaMonitorWithAuth.sh [new file with mode: 0644] blob
src/main/scripts/cambriaSimpleTextPubWithAuth.sh [new file with mode: 0644] blob
src/main/scripts/cambriaSimpleTextPublisher.sh [new file with mode: 0644] blob
src/main/scripts/cambriaTool.sh [new file with mode: 0644] blob
src/main/scripts/swmpkgclean.sh [new file with mode: 0644] blob
src/main/swm/common/common.env [new file with mode: 0644] blob
src/main/swm/common/deinstall.env [new file with mode: 0644] blob
src/main/swm/common/deinstall_postproc.sh [new file with mode: 0644] blob
src/main/swm/common/deinstall_preproc.sh [new file with mode: 0644] blob
src/main/swm/common/install.env [new file with mode: 0644] blob
src/main/swm/common/install_postproc.sh [new file with mode: 0644] blob
src/main/swm/common/install_preproc.sh [new file with mode: 0644] blob
src/main/swm/common/localize.sh [new file with mode: 0644] blob
src/main/swm/deinstall/postproc/post_proc [new file with mode: 0644] blob
src/main/swm/deinstall/preproc/pre_proc [new file with mode: 0644] blob
src/main/swm/descriptor.xml [new file with mode: 0644] blob
src/main/swm/fallback/postproc/post_proc [new file with mode: 0644] blob
src/main/swm/fallback/preproc/pre_proc [new file with mode: 0644] blob
src/main/swm/initinst/postproc/post_proc [new file with mode: 0644] blob
src/main/swm/initinst/preproc/pre_proc [new file with mode: 0644] blob
src/main/swm/install/postproc/post_proc [new file with mode: 0644] blob
src/main/swm/install/preproc/pre_proc [new file with mode: 0644] blob
src/main/webapp/WEB-INF/spring-context.xml [new file with mode: 0644] blob
src/main/webapp/WEB-INF/web.xml [new file with mode: 0644] blob
src/test/java/com/att/sa/cambria/testClient/SimpleExample.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/ApiKeyBean.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DMaapPubSubTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DMaapTopicTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DmaapAdminTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DmaapApiKeyTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/DmaapMetricsTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/JUnitTestSuite.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/LoadPropertyFile.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/TestRunner.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dmaap/TopicBean.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/ApiKeyBean.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2AdminTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ApiKeyTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ConsumerFilterTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ConsumerTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2MetricsTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2ProducerTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/DME2TopicTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/JUnitTestSuite.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/LoadPropertyFile.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/TestRunner.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/mr/test/dme2/TopicBeanDME2.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaApiTestCase.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/CambriaRateLimiterTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/msgrtr/nsa/cambria/utils/UtilsTest.java [new file with mode: 0644] blob
Provides REST API for messaging. It is built on top of Apache Kafka. ( READ ONLY - Repository has been moved.)