第148章 HL7 DataFormat

Spring XML ファイルでは、ポート 8888 で TCP を使用して HL7 リクエストをリッスンするように mina2 エンドポイントを設定します。

<endpoint id="hl7MinaListener" uri="mina2:tcp://localhost:8888?sync=true&amp;codec=#hl7codec"/>

sync=true は、このリスナーが同期的であるため、HL7 応答を呼び出し元に返すことを示します。HL7 コーデックは、codec=#hl7codec で設定されます。hl7codec は単なる Spring Bean ID であるため、mygreatcodecforhl7 などの名前を指定できることに注意してください。コーデックは、Spring XML ファイルにも設定されています。

<bean id="hl7codec" class="org.apache.camel.component.hl7.HL7MLLPCodec">
    <property name="charset" value="iso-8859-1"/>
</bean>

次の Java DSL の例が示すように、エンドポイント hl7MinaLlistener をルートでコンシューマーとして使用できます。

from("hl7MinaListener")
  .bean("patientLookupService");

これは、HL7 をリッスンし、patientLookupService という名前のサービスにルーティングする非常に単純なルートです。これは Spring Bean ID でもあり、Spring XML で次のように設定されます。

<bean id="patientLookupService" class="com.mycompany.healthcare.service.PatientLookupService"/>

次に示すように、Camel に依存しない POJO クラスでビジネスロジックを実装できます。

import ca.uhn.hl7v2.HL7Exception;
import ca.uhn.hl7v2.model.Message;
import ca.uhn.hl7v2.model.v24.segment.QRD;

public class PatientLookupService {
    public Message lookupPatient(Message input) throws HL7Exception {
        QRD qrd = (QRD)input.get("QRD");
        String patientId = qrd.getWhoSubjectFilter(0).getIDNumber().getValue();

        // find patient data based on the patient id and create a HL7 model object with the response
        Message response = ... create and set response data
        return response
    }

Spring XML ファイルでは、ポート 8888 で TCP を使用して HL7 リクエストをリッスンするように netty4 エンドポイントを設定します。

<endpoint id="hl7NettyListener" uri="netty4:tcp://localhost:8888?sync=true&amp;encoder=#hl7encoder&amp;decoder=#hl7decoder"/>

sync=true は、このリスナーが同期的であるため、HL7 応答を呼び出し元に返すことを示します。HL7 コーデックは、encoder=#hl7encoder*and*decoder=#hl7decoder でセットアップされます。hl7encoder と hl7decoder は単なる Bean ID であるため、異なる名前が付けられる可能性があることに注意してください。Bean は Spring XML ファイルで設定できます。

<bean id="hl7decoder" class="org.apache.camel.component.hl7.HL7MLLPNettyDecoderFactory"/>
<bean id="hl7encoder" class="org.apache.camel.component.hl7.HL7MLLPNettyEncoderFactory"/>

次の Java DSL の例が示すように、エンドポイント hl7NettyListener をコンシューマーとしてルートで使用できます。

from("hl7NettyListener")
  .bean("patientLookupService");