Code Review / dmaap / messagerouter / dmaapclient.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: ffc0ccd) | patch
Add Initial Code Import 67/9567/1
authorVarun Gudisena <vg411h@att.com>
Thu, 31 Aug 2017 01:49:32 +0000 (20:49 -0500)
committerVarun Gudisena <vg411h@att.com>
Thu, 31 Aug 2017 01:50:47 +0000 (20:50 -0500)
commitcc9de9bc6803212f0233e0e1bf06aa63fe8b7a6a
tree7425883592f6cfe97c415f17ca80a0ba13041ce2tree | snapshot
parentffc0ccd5ab1ad5e6a5db2d674a4a6c30a31bc732commit | diff
Add Initial Code Import

Intial Code import for dmaapClient

Issue-id: DMAAP-82
Change-Id: Ib627672d37e233b796619f93dd91f5caaf1592e4
Signed-off-by: Varun Gudisena <vg411h@att.com>
81 files changed:
.gitignore [new file with mode: 0644] blob
License.txt [new file with mode: 0644] blob
README.md [new file with mode: 0644] blob
pom.xml [new file with mode: 0644] blob
src/main/bash/cambriaDel.sh [new file with mode: 0644] blob
src/main/bash/cambriaGet.sh [new file with mode: 0644] blob
src/main/bash/cambriaPost.sh [new file with mode: 0644] blob
src/main/bash/cambriaPut.sh [new file with mode: 0644] blob
src/main/cpp/cambria.cpp [new file with mode: 0644] blob
src/main/cpp/cambria.h [new file with mode: 0644] blob
src/main/cpp/loopingPostClient.cpp [new file with mode: 0644] blob
src/main/cpp/make.sh [new file with mode: 0644] blob
src/main/cpp/sampleGetClient.cpp [new file with mode: 0644] blob
src/main/cpp/samplePostClient.cpp [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/HostSelector.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRBatchingPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRClient.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRClientBuilders.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRClientFactory.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRConsumer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRIdentityManager.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/MRTopicManager.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/Clock.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRBaseClient.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRBatchPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRClientVersionInfo.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRConstants.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRConsumerImpl.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRFormat.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRMetaClient.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRSimplerBatchPublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/response/MRConsumerResponse.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/response/MRPublisherResponse.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/dme/client/DefaultLoggingFailoverFaultHandler.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/dme/client/HeaderReplyHandler.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/dme/client/PreferredRouteReplyHandler.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/dme/client/PreferredRouteRequestHandler.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/dme/client/SimpleExampleConsumer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/dme/client/SimpleExamplePublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/logging/MRAppender.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/ConsolePublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/ProtocolTypeConstants.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/SampleConsumer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/SamplePublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/SimpleExampleConsumer.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/SimpleExamplePublisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/clients/SimpleExamplePublisherWithResponse.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/support/MRBatchingPublisherMock.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/test/support/MRConsumerMock.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/ApiKeyCommand.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/AuthCommand.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/ClusterCommand.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/MRCommandContext.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/MRTool.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/MessageCommand.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/TopicCommand.java [new file with mode: 0644] blob
src/main/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/tools/TraceCommand.java [new file with mode: 0644] blob
src/main/resources/MRClientVersion.properties [new file with mode: 0644] blob
src/main/resources/dme2/consumer.properties [new file with mode: 0644] blob
src/main/resources/dme2/message.txt [new file with mode: 0644] blob
src/main/resources/dme2/preferredRoute.txt [new file with mode: 0644] blob
src/main/resources/dme2/producer.properties [new file with mode: 0644] blob
src/main/resources/log4j.xml [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRConstantsTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dmaap/messagerouter/dmaapclient/nsa/mr/client/impl/MRConsumerImplTest.java [new file with mode: 0644] blob
src/test/resources/log4j.xml [new file with mode: 0644] blob
test/MRToolTestNotes.txt [new file with mode: 0644] blob
test/arraySample.json [new file with mode: 0644] blob
test/eightyThousand.camb [new file with mode: 0644] blob
test/fiveThousand.json [new file with mode: 0644] blob
test/fortyThousand.camb [new file with mode: 0644] blob
test/none.json [new file with mode: 0644] blob
test/oneThousand.json [new file with mode: 0644] blob
test/postCambriaEvent.sh [new file with mode: 0644] blob
test/postJsonEvent.sh [new file with mode: 0644] blob
test/sample.json [new file with mode: 0644] blob
test/tenThousand.camb [new file with mode: 0644] blob
test/tenThousand.json [new file with mode: 0644] blob
test/twentyThousand.camb [new file with mode: 0644] blob
It's a message router client. uses DME2 ( Direct Messaging Engine ) library to locate the end point.