gerrit.onap Code Review - dcaegen2/collectors/ves.git/commit

Code Review / dcaegen2 / collectors / ves.git / commit

author	Maciej Malewski <maciej.malewski@nokia.com>
	Tue, 8 Jun 2021 07:04:48 +0000 (09:04 +0200)
committer	Maciej Malewski <maciej.malewski@nokia.com>
	Thu, 17 Jun 2021 08:03:49 +0000 (10:03 +0200)
commit	74b598291ed2461e0e482f556baf2943a97a54f2
tree	22e1140bc0f27680be4d47d40b0c94f7205b45b3	tree \| snapshot
parent	26be283f4a7044aea4ee0ca480fde20eb5233ee2	commit \| 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: I945c38b4ab04b697ecfabd5ce38502f83fa70d1a

55 files changed:

Changelog.md		diff \| blob \| history
README.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

RSS Atom