Package org.linuxforhealth.fhir.server.notification.kafka

Class FHIRNotificationKafkaPublisher.KafkaPublisherCallback

  • All Implemented Interfaces:
    org.apache.kafka.clients.producer.Callback
    Enclosing class:
    FHIRNotificationKafkaPublisher
    public class FHIRNotificationKafkaPublisher.KafkaPublisherCallback
extends java.lang.Object
implements org.apache.kafka.clients.producer.Callback

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onCompletion​(org.apache.kafka.clients.producer.RecordMetadata recordMetadata, java.lang.Exception exception)
      This method is called by the KafkaProducer API after a successful *or* unsuccessful send.

      • Methods inherited from class java.lang.Object

        clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • KafkaPublisherCallback

        public KafkaPublisherCallback​(FHIRNotificationEvent event,
                              java.lang.String notificationEvent,
                              java.lang.String topicId)

    • Method Detail

      • onCompletion

        public void onCompletion​(org.apache.kafka.clients.producer.RecordMetadata recordMetadata,
                         java.lang.Exception exception)
        This method is called by the KafkaProducer API after a successful *or* unsuccessful send.
        Specified by:
        onCompletion in interface org.apache.kafka.clients.producer.Callback