Cada mensaje clínico, hasta el acuse.

MSH|^~\&|HIS|CLINICA|TITAN|CLINICA|20260830090000||ORM^O01|MSG-00042|P|2.5.1
PID|0001||11111111-1^^^1|PACIENTE DE PRUEBA^TEST||19750322|F
PV1|1|O|IMAGEN|||||99999-9^MEDICO DE PRUEBA^EJEMPLO
ORC|NW|400-1^IMAGEN||||||20260830090000
OBR|1|400-1^IMAGEN||224^ECOTOMOGRAFIA DOPPLER^IMG

{
  "mensaje": "ORM^O01",
  "control_id": "MSG-00042",
  "paciente": {
    "documento": "11111111-1",
    "nombre": "TEST PACIENTE DE PRUEBA",
    "nacimiento": "1975-03-22"
  },
  "solicitante": "99999-9",
  "examenes": [
    { "orden": "400-1", "codigo": "224", "nombre": "ECOTOMOGRAFIA DOPPLER" }
  ]
}

channels:
  - slug: orm-inbound
    source:
      type: mllp_listener
      port: 6679
      message_type: ORM^O01
    transformers:
      - type: field_mapper
        mapping: orm-o01-inbound@1.0.0
    destinations:
      - type: http
        url: https://his.interno/api/ordenes
        outbox: true          # reintentos + DLQ

# Sólo los informes de imagenología de estos exámenes siguen por el canal.
- type: filter
  config:
    match: all
    conditions:
      - { field: "$.mensaje",             operator: equals,    value: "ORU^R01" }
      - { field: "$.examenes.0.codigo", operator: in,        value: ["224", "581"] }
      - { field: "$.paciente.rut",      operator: not_empty }

# Lo que no cumple se registra como filtrado, no como falla del canal.

// El mismo script que sus integradores ya escriben en Mirth: recibe el
// mensaje y devuelve el mensaje. Corre aislado y con tiempo máximo.

message.paciente.rut = message.paciente.rut.replace(/\./g, '');

message.examenes = message.examenes.map(function (examen) {
  examen.codigo = examen.codigo.padStart(6, '0');
  return examen;
});

if (!message.examenes.length) return null;   // null descarta el mensaje

return message;

# Un informe con tres exámenes se entrega como tres mensajes, cada uno con
# el paciente y la cabecera completos.
- type: splitter
  config:
    field: "$.examenes"
    index_field: parte     # 1, 2, 3…
    total_field: partes    # 3

# Si un filtro posterior descarta una parte, las otras siguen.
# Si una falla, el mensaje entero va a la cola de fallidos: media entrega
# clínica es peor que ninguna.

# El patrón que ya usan hoy: la integración deja la orden en la base del
# HIS —tabla o procedimiento— y el sistema receptor la levanta de ahí.
destinations:
  - type: database
    connection_string: "oracle://titan@his-db:1521/CLINICAS_PROD"
    statement: "BEGIN sp_recibir_orden(:1, :2, :3); END;"
    params: ["$.folio", "$.paciente.rut", "$"]
    outbox: true

# Oracle por driver propio —sin Instant Client ni OCI en el servidor—, y
# también PostgreSQL, MySQL y SQL Server. Un campo que falta en el mensaje
# corta la entrega: nunca se escribe un NULL en su lugar.

# Salida hacia una API FHIR gestionada, con el token renovándose solo.
destinations:
  - type: http
    url: https://fhir.clinica.cl/r4/ServiceRequest
    headers: { Content-Type: application/fhir+json }
    auth:
      type: oauth2
      token_url: https://auth.clinica.cl/oauth2/token
      client_id: titan-integracion
      private_key_file: /etc/titan/tls/titan.pem   # SMART backend services
      scope: system/ServiceRequest.write
    outbox: true                                # reintentos + cola de fallidos

GET /api/batches/MSG-00042

{
  "batch_id": "MSG-00042",
  "status": "partial",
  "total": 3,
  "delivered": 2,
  "pending": 1,
  "failed": 0,
  "deliveries": [
    { "id": "dlv_7f3a", "destination": "mllp",     "status": "delivered", "attempts": 1 },
    { "id": "dlv_7f3b", "destination": "database", "status": "delivered", "attempts": 1 },
    { "id": "dlv_7f3c", "destination": "http",     "status": "pending",   "attempts": 2 }
  ]
}

# El contenido del mensaje no se devuelve acá: puede llevar datos del
# paciente, y este endpoint es de estado, no de recuperación.