Class FHIRNotificationKafkaPublisher
- java.lang.Object
-
- org.linuxforhealth.fhir.server.notification.kafka.FHIRNotificationKafkaPublisher
-
- All Implemented Interfaces:
FHIRNotificationSubscriber
public class FHIRNotificationKafkaPublisher extends java.lang.Object implements FHIRNotificationSubscriber
This class implements the FHIR server notification service via a Kafka topic.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
FHIRNotificationKafkaPublisher.KafkaPublisherCallback
-
Constructor Summary
Constructors Modifier Constructor Description protected
FHIRNotificationKafkaPublisher()
FHIRNotificationKafkaPublisher(java.lang.String topicName, java.util.Properties kafkaProps)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
notify(FHIRNotificationEvent event)
Notify subscriber of an eventvoid
shutdown()
Performs any necessary "shutdown" logic to disconnect from the topic.
-
-
-
Method Detail
-
shutdown
public void shutdown()
Performs any necessary "shutdown" logic to disconnect from the topic.
-
notify
public void notify(FHIRNotificationEvent event) throws FHIRNotificationException
Description copied from interface:FHIRNotificationSubscriber
Notify subscriber of an event- Specified by:
notify
in interfaceFHIRNotificationSubscriber
- Throws:
FHIRNotificationException
-
-