...
Code Block | ||||
---|---|---|---|---|
| ||||
public class SubscriptionCreatedEventConsumer { @KafkaListener(topics = "${app.ncmp.cm-avc-subscription.topic}") //Blocking: See issue #2 public void consumeSubscriptionEvent(final SubscriptionCreatedEvent subscriptionCreatedEvent){ if(subscriptionCreatedEvent.dataCategory == 'CM'){ //Check dataCategory log.debug(consuming"Consuming event {} subscriptionCreatedEvent...", subscriptionCreatedEvent); if(checkFormat(subscriptionCreatedEvent)){ //Check format of message Subscription createSubscription = new Subscription() //Create Object log.debug("subscription created "+ createSubscription) //Log subscription } } } public boolean checkFormat(SubscriptionCreatedEvent event){ //DetermineBlocking: whenSee schemaissue confirmed#1 } } |
Subscription Object - Will be finalised when schema confirmed
...
# | Issue | Notes | Decision | |||||||
---|---|---|---|---|---|---|---|---|---|---|
1 | Subscription Event Scheme | Protocol : Kafka Event
| ||||||||
2 | Configurable Topic | Pointer where previously implemented |