Code Review / dcaegen2 / collectors / ves.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 26be283) | patch
Replace cambria with DmaaP client 35/121735/7
authorMaciej Malewski <maciej.malewski@nokia.com>
Tue, 8 Jun 2021 07:04:48 +0000 (09:04 +0200)
committerMaciej Malewski <maciej.malewski@nokia.com>
Wed, 16 Jun 2021 12:17:34 +0000 (14:17 +0200)
commit430cf11bbcb447316f831e1dd1b8760abeaa9171
tree016bf553772496117d2a2c2de3b858e3b7f67854tree | snapshot
parent26be283f4a7044aea4ee0ca480fde20eb5233ee2commit | diff
Replace cambria with DmaaP client

- remove cambria, add DmaaP client
- sending event for many topics at once is no longer supported
- add backward compatibility status codes
- add additional validation for batchEvent

Issue-ID: DCAEGEN2-1483
Signed-off-by: Maciej Malewski <maciej.malewski@nokia.com>
Change-Id: I502e1b21af217a07f8432b14dd833dfb3c139975
54 files changed:
Changelog.md diff | blob | history
dpo/data-formats/ves-dmaap-config.json [deleted file] blob | history
etc/DmaapConfig.json [deleted file] blob | history
etc/collector.properties diff | blob | history
etc/ves-dmaap-config.json [new file with mode: 0644] blob
pom.xml diff | blob | history
src/main/java/org/onap/dcae/ApplicationSettings.java diff | blob | history
src/main/java/org/onap/dcae/common/EventSender.java diff | blob | history
src/main/java/org/onap/dcae/common/VESLogger.java [deleted file] blob | history
src/main/java/org/onap/dcae/common/model/BackwardsCompatibilityException.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/common/model/InternalException.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/common/model/PayloadToLargeException.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/common/model/VesEvent.java diff | blob | history
src/main/java/org/onap/dcae/common/publishing/DMaaPConfigurationParser.java diff | blob | history
src/main/java/org/onap/dcae/common/publishing/DMaaPEventPublisher.java diff | blob | history
src/main/java/org/onap/dcae/common/publishing/DMaaPPublishersBuilder.java [deleted file] blob | history
src/main/java/org/onap/dcae/common/publishing/DMaaPPublishersCache.java [deleted file] blob | history
src/main/java/org/onap/dcae/common/publishing/DmaapRequestConfiguration.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/common/publishing/MessageRouterHttpStatusMapper.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/common/publishing/Publisher.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/common/publishing/PublisherConfig.java diff | blob | history
src/main/java/org/onap/dcae/common/validator/BatchEventValidator.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/common/validator/GeneralEventValidator.java diff | blob | history
src/main/java/org/onap/dcae/multiplestreamreducer/MultipleStreamReducer.java [new file with mode: 0644] blob
src/main/java/org/onap/dcae/restapi/ApiException.java diff | blob | history
src/main/java/org/onap/dcae/restapi/VesRestController.java diff | blob | history
src/main/resources/log4j2.xml diff | blob | history
src/test/java/org/onap/dcae/ApplicationSettingsTest.java diff | blob | history
src/test/java/org/onap/dcae/TLSTest.java diff | blob | history
src/test/java/org/onap/dcae/common/EventSenderTest.java diff | blob | history
src/test/java/org/onap/dcae/common/publishing/DMaaPConfigurationParserTest.java diff | blob | history
src/test/java/org/onap/dcae/common/publishing/DMaaPEventPublisherTest.java [deleted file] blob | history
src/test/java/org/onap/dcae/common/publishing/DMaaPPublishersCacheTest.java [deleted file] blob | history
src/test/java/org/onap/dcae/common/publishing/DMaapContainer.java [new file with mode: 0644] blob
src/test/java/org/onap/dcae/common/publishing/MessageRouterHttpStatusMapperTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dcae/common/publishing/PublisherTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dcae/common/publishing/PublisherTestMockServer.java [new file with mode: 0644] blob
src/test/java/org/onap/dcae/common/validator/BatchEventValidatorTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dcae/multiplestreamreducer/MultipleStreamReducerTest.java [new file with mode: 0644] blob
src/test/java/org/onap/dcae/restapi/ApiAuthInterceptionTest.java diff | blob | history
src/test/java/org/onap/dcae/restapi/VesRestControllerTest.java diff | blob | history
src/test/java/org/onap/dcae/vestest/TestVESLogger.java [deleted file] blob | history
src/test/resources/dmaap-msg-router/MsgRtrApi.properties [new file with mode: 0644] blob
src/test/resources/dmaap-msg-router/cadi.properties [new file with mode: 0644] blob
src/test/resources/dmaap-msg-router/logback.xml [new file with mode: 0644] blob
src/test/resources/dmaap-msg-router/message-router-compose.yml [new file with mode: 0644] blob
src/test/resources/dmaap-msg-router/zk_client_jaas.conf [new file with mode: 0644] blob
src/test/resources/dmaap-msg-router/zk_server_jaas.conf [new file with mode: 0644] blob
src/test/resources/testParseDMaaPCredentialsLegacy.json [deleted file] blob | history
src/test/resources/testParseDMaaPLegacy.json [deleted file] blob | history
src/test/resources/ves7_batch_stdnDefined_withDifferentStndDefinedNamespace.json [new file with mode: 0644] blob
src/test/resources/ves7_batch_stdnDefined_withSameStndDefinedNamespace.json [new file with mode: 0644] blob
src/test/resources/ves7_batch_valid_two_different_domain.json [new file with mode: 0644] blob
version.properties diff | blob | history
VNF Event Streaming collector