Interface IMessageHandler
-
public interface IMessageHandler
Our interface for handling messages received by the consumer. Used to decouple the Kafka consumer from the database persistence logic
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
Close any resources held by the handlervoid
process(java.util.List<java.lang.String> messages)
Ask the handler to process the list of messages.
-
-
-
Method Detail
-
process
void process(java.util.List<java.lang.String> messages) throws FHIRPersistenceException
Ask the handler to process the list of messages.- Parameters:
messages
-- Throws:
FHIRPersistenceException
-
close
void close()
Close any resources held by the handler
-
-