FHIRNotificationKafkaPublisher (LinuxForHealth FHIR Server)

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 event
`void`	`shutdown()`	Performs any necessary "shutdown" logic to disconnect from the topic.

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - FHIRNotificationKafkaPublisher
```
protected FHIRNotificationKafkaPublisher()
```
  - FHIRNotificationKafkaPublisher
```
public FHIRNotificationKafkaPublisher(java.lang.String topicName,
                                      java.util.Properties kafkaProps)
```
- 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 interface FHIRNotificationSubscriber
    
    Throws:
    
    FHIRNotificationException