FHIR-PEX

The FHIR-Kafka application leverages the interoperability capabilities of the PEX in JAVA from InterSystems IRIS to categorize examinations into quarantine based on configured rules, dynamically directing JSON FHIR structures related to the “Observation” resource to specific topics in Apache Kafka. It capitalizes on the flexibility of PEX to define advanced quarantine criteria, enabling seamless integration between healthcare systems and the Kafka messaging infrastructure.

How it works

When the system receives a FHIR message through Kafka, it is processed within a Java PEX, and then forwarded to topics based on rules configured in globals.

sample:

Set ^quarantineRule("59462-2","http://loinc.org") = $LB(">=","500") 

The “Observation” exams with code “59462-2” and system “http://loinc.org”, in the project testosterone.json, with “valueQuantity”.“value” greater or equal to 500, will be sent to quarantine

the same behavior can be done for observations that use valueCodeableConcept

set ^quarantineRule("94531-1","http://loinc.org") = $LB("valueCodeableConcept","10828004", "http://snomed.info/sct") \

The project also includes a Java application that consumes messages from the “observation_quarantine” topic and persists them in the IRIS database using ORM with Quarkus, specifically employing the Quarkus Hibernate ORM dialect: quarkus.hibernate-orm.dialect=io.github.yurimarx.hibernateirisdialect.InterSystemsIRISDialect.

This Java application, send a messages to U.I Monitor quarantine, where there is an integration with ChatGPT, implemented using langchain4j, to recommend future exams to the patient, through their health history.

Article - how it works

Sending Kafka messages via JAVA PEX for processing quarantine exam prognoses.

Prerequisites

Make sure you have git and Docker desktop installed.

Installation

Clone/git pull the repo into any local directory

$ git clone https://github.com/flavioneubauer/fhir-pex.git

To enable integration with chatGPT, enter your OPENAI_API_KEY by changing the quarkus-backend environment

  quarkus-backend:
    image: quarkus-quarentine-monitor:latest
    build:
      dockerfile: src/main/docker/Dockerfile.jvm
      context: java-orm
    ports:
      - 8080:8080
    restart: always
    depends_on:
      - iris
      - kafka
    environment:
      - QUARKUS_LANGCHAIN4J_OPENAI_API_KEY=YOUR_KEY
      - QUARKUS_DATASOURCE_JDBC_URL=jdbc:IRIS://iris:1972/USER
      - KAFKA_BOOTSTRAP_SERVERS=kafka:9092

Open the terminal in this directory and run:

$ docker-compose build && docker-compose up -d

What’s inside

U.I:

• InterSystems IRIS: http://localhost:52774/csp/user/EnsPortal.ProductionConfig.zen
• Eco Kafka Manager: http://localhost:8082/
• Monitor quarantine: http://localhost:8080/

All ports:

• SuperServer: 51774
• Java Gateway: 55555
• Zookeeper: 2181
• Kafka: 9092
• Kafka Manager: 8082
• quarkus backend: 8082

Video demo

VIDEO

authors

• Davi Massaru Teixeira Muta
• Flavio Neubauer