Package com.ibm.fhir.notifications.kafka.impl

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

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.

Methods inherited from class java.lang.Object

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

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 interface org.apache.kafka.clients.producer.Callback