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 event {} ...", 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){
//Blocking: See issue #1
}
}
| 