图 3. 中介模块

 
　　中介模块包含一个名为 MedicationSPLExport 的导出，并带有一个 Web 服务绑定和一个简单的接口。该模块还有两个导入，这两个导入都具有 Web 服务绑定：

　　MedicationServiceImport：此导入绑定到内部服务，以检索将用于执行 XQuery 的所需药品的唯一 ID。

　　HL7ServiceImport：此导入绑定到 alphaWorks SPL 数据服务，用来检索药品的 XML 描述（给定了唯一 ID）。

　　如图 3 中的组装图所示，中介模块还包含一个名为 InvokeHL7Service 的 Java Service Component Architecture (SCA) 组件，该组件表示用于调用 HL7 数据服务的自定义中介元素中包含的代码。下文还将谈到这一点。

　　元素的相互连接非常简单。需要说明的唯一连接是 InvokeHL7Service 和 HL7ServiceImport 之间的连接。此连接可让自定义中介在查找中使用服务合作伙伴的符号名称来调用相应的服务。换句话说，我们不必将被调用服务的端点地址硬编码到自定义中介中。

　　简言之，中介流的目标是调用请求路径上的一个内部 Web 服务，并使用从该服务获得的信息作为响应路径的一部分来调用另一 Web 服务。图 4 显示了中介流组件的请求路径。

　　图 4. 中介流组件的请求路径

 
　　XSLTranformation1 的目标是将 MedicationSPL 接口（中介模块向其客户端公开的接口）转换为中介接口（即内部 Web 服务的接口）。在转换中使用了一个常规 XSLT 样式表。在请求路径中，使用 MedicationSPL 中提供的名称调用内部服务来获得 UUID。返回的值为 UUID。然后将 UUID（为进行演示已对其进行硬编码）插入到要在响应路径中使用的服务消息对象，以便调用 HL7 SPL 数据服务。

　　图 5. 中介流组件的响应路径

 
　　中介流组件的响应路径如图 5 所示。此流程的目标是使用从内部服务返回的数据形成 XQuery 并调用 HL7 服务（使用自定义代码中介元素执行此操作）。此自定义中介元素的目的是获取内部 Web 服务（存储于 SMO 中）返回的值，使用该值构建 XQuery，并将其传递到 HL7 Web 服务。清单 3 描述了自定义中介元素的实现。

　　清单 3. 自定义中介实现
               
public DataObject mediate(DataObject input1) {

 System.out.println("In Response Mediation");
 System.out.println("invoke service and extract response payload");
 ServiceManager serviceManager = ServiceManager.INSTANCE;
 BOFactory bofactory = (BOFactory) serviceManager
   .locateService("com/ibm/websphere/bo/BOFactory");

 System.out.println("Before Locating Service After Getting Object");

 //(1) Building XPath while extracting the payload from the
 // incoming SMO input1.getString("body/GetStringResponse/GetStringReturn")

 String query = "XQUERY declare default element namespace "urn:hl7-org:v3";for
  $doc in db2-fn:xmlcolumn(‘DB2INST1.HL7.DOCUMENT’)/PORP_IN000001
  where $doc/receiver/device/id/@root=""
   + input1.getString("body/GetStringResponse/GetStringReturn")
   + "" return $doc";
  
  
 //(2) Creating Elements for HL7 Service and setting it’s payload to the Built Xquery
 DataObject runXquery = bofactory.createByElement(
   "http://schemas.ibm.com/hl7/hl7/hl7.dadx", "runxquery");
 runXquery.setString("query", query);
 System.out.println("After Setting Object");

 System.out.println("invoke HL7 service ");

 //(3) invoking the webservice by locating the service providing the operation name 
 // and passing in the newly created DataObject as the input Parameters
  
 Service myService = (Service) ServiceManager.INSTANCE
 .locateService("theSoapPortTypePartner");
 DataObject Hl7Response = (DataObject) myService.invoke("runxquery",
   runXquery);
  
 System.out.println("Getting returned from HL7");

 DataObject Hl7ResponseOutPut = Hl7Response.getDataObject("queryresult");
  

 // (4)Adjusting Return Values for Polocies External
 DataObject message = bofactory.createByMessage(
   "http://MedicationSPLModule/MedicationSPL",
   "getSPLInfoResponseMsg");
 DataObject myRes = bofactory.createByElement(
   "http://MedicationSPLModule/MedicationSPL",
   "getSPLInfoResponse");

 myRes.setDataObject("SPLDocument", hl7ResponseOutPut);
 System.out.println("2");
 System.out.println(message);
 message.setDataObject("getSPLInfoResult", myRes);
 input1.setDataObject("body", message);
 System.out.println("leaving Response");

 return input1;
}