Class FHIRNotificationKafkaPublisher.KafkaPublisherCallback
- java.lang.Object
-
- com.ibm.fhir.notifications.kafka.impl.FHIRNotificationKafkaPublisher.KafkaPublisherCallback
-
- All Implemented Interfaces:
org.apache.kafka.clients.producer.Callback
- Enclosing class:
- FHIRNotificationKafkaPublisher
public class FHIRNotificationKafkaPublisher.KafkaPublisherCallback extends Object implements org.apache.kafka.clients.producer.Callback
-
-
Constructor Summary
Constructors Constructor Description KafkaPublisherCallback(FHIRNotificationEvent event, String notificationEvent, String topicId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onCompletion(org.apache.kafka.clients.producer.RecordMetadata recordMetadata, Exception exception)
This method is called by the KafkaProducer API after a successful *or* unsuccessful send.
-
-
-
Constructor Detail
-
KafkaPublisherCallback
public KafkaPublisherCallback(FHIRNotificationEvent event, String notificationEvent, String topicId)
-
-
Method Detail
-
onCompletion
public void onCompletion(org.apache.kafka.clients.producer.RecordMetadata recordMetadata, Exception exception)
This method is called by the KafkaProducer API after a successful *or* unsuccessful send.- Specified by:
onCompletion
in interfaceorg.apache.kafka.clients.producer.Callback
-
-