gerrit.onap Code Review - cps/cps-temporal.git/commit

Code Review / cps / cps-temporal.git / commit

author	Bruno Sakoto <bruno.sakoto@bell.ca>
	Fri, 4 Jun 2021 11:49:14 +0000 (07:49 -0400)
committer	Bruno Sakoto <bruno.sakoto@bell.ca>
	Mon, 5 Jul 2021 22:37:15 +0000 (18:37 -0400)
commit	c9b99347c7c425fce7a1f5f3c7e2ac500f2f0c5c
tree	199b49d2db987f2c630de124356a48b1bd97657a	tree \| snapshot
parent	8b2193b7ed06e2ee6a90f7986921e72ca70ad90f	commit \| diff

Add kafka listener for data updated events

See "Running via Docker Compose" section from README.md file to have an
example of event processing

Issue-ID: CPS-371
Signed-off-by: Bruno Sakoto <bruno.sakoto@bell.ca>
Change-Id: Id3abfa32fb04e07102a5f28e6e43a9b533391188

25 files changed:

README.md		diff \| blob \| history
docker-compose.yml		diff \| blob \| history
pom.xml		diff \| blob \| history
src/main/java/org/onap/cps/temporal/controller/event/listener/exception/EventListenerException.java	[new file with mode: 0644]	blob
src/main/java/org/onap/cps/temporal/controller/event/listener/exception/InvalidEventEnvelopException.java	[new file with mode: 0644]	blob
src/main/java/org/onap/cps/temporal/controller/event/listener/kafka/DataUpdatedEventListener.java	[new file with mode: 0644]	blob
src/main/java/org/onap/cps/temporal/controller/event/listener/kafka/DataUpdatedEventListenerErrorHandler.java	[new file with mode: 0644]	blob
src/main/java/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapper.java	[new file with mode: 0644]	blob
src/main/java/org/onap/cps/temporal/controller/web/QueryController.java	[moved from src/main/java/org/onap/cps/temporal/controller/QueryController.java with 96% similarity]	diff \| blob \| history
src/main/java/org/onap/cps/temporal/domain/NetworkData.java		diff \| blob \| history
src/main/java/org/onap/cps/temporal/domain/NetworkDataId.java		diff \| blob \| history
src/main/java/org/onap/cps/temporal/service/NetworkDataServiceImpl.java		diff \| blob \| history
src/main/java/org/onap/cps/temporal/service/ServiceException.java	[new file with mode: 0644]	blob
src/main/resources/application-sasl-ssl-kafka.yml	[new file with mode: 0644]	blob
src/main/resources/application.yml		diff \| blob \| history
src/main/resources/logback.xml	[new file with mode: 0644]	blob
src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/DataUpdatedEventListenerIntegrationSpec.groovy	[new file with mode: 0644]	blob
src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/DataUpdatedEventListenerSpec.groovy	[new file with mode: 0644]	blob
src/test/groovy/org/onap/cps/temporal/controller/event/listener/kafka/EventFixtures.groovy	[new file with mode: 0644]	blob
src/test/groovy/org/onap/cps/temporal/controller/event/model/CpsDataUpdatedEventMapperSpec.groovy	[new file with mode: 0644]	blob
src/test/groovy/org/onap/cps/temporal/controller/web/QueryControllerSpec.groovy	[moved from src/test/groovy/org/onap/cps/temporal/controller/QueryControllerSpec.groovy with 96% similarity]	diff \| blob \| history
src/test/groovy/org/onap/cps/temporal/repository/NetworkDataRepositorySpec.groovy		diff \| blob \| history
src/test/groovy/org/onap/cps/temporal/service/NetworkDataServiceImplSpec.groovy		diff \| blob \| history
src/test/java/org/onap/cps/temporal/architecture/LayeredArchitectureTest.java		diff \| blob \| history
src/test/resources/application.yml		diff \| blob \| history

"cps-temporal"

RSS Atom