...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
/** * Consume the specified event. * * @param cpsDataUpdatedEvent the data updated event to be consumed and persisted. */ @KafkaListener(topics = "${app.listener.data-updated.topic}", errorHandler = "dataUpdatedEventListenerErrorHandler") public void consume(final CpsDataUpdatedEvent cpsDataUpdatedEvent) { log.debug("Receiving {} ...", cpsDataUpdatedEvent); // Validate event envelop validateEventEnvelop(cpsDataUpdatedEvent); // Map event to entity final var networkData = this.cpsDataUpdatedEventMapper.eventToEntity(cpsDataUpdatedEvent); log.debug("Persisting {} ...", networkData); // Persist entity final var persistedNetworkData = this.networkDataService.addNetworkData(networkData); log.debug("Persisted {}", persistedNetworkData); } |
...