基于 WESB/WPS 实现 SOAP 和 JMS 消息头的转换

/**
 * Method generated to support implemention of operation "mediate" defined for WSDL port
 * type named "interface.CusMedInterface".
 * 
 * The presence of commonj.sdo.DataObject as the return type and/or as a parameter 
 * type conveys that its a complex type. Please refer to the WSDL Definition for more
 * information on the type of input, output and fault(s).
 */
public DataObject mediate(DataObject input1) {
  // To override the generated Java Snippet, please comment out the following method call
  sca.component.mediation.java.impl.CusMedInterfacePartnerCustomLogic.JavaSnippet snippet
      = new sca.component.mediation.java.impl.CusMedInterfacePartnerCustomLogic
          .JavaSnippet();
  return snippet.execute(input1);
}
      

/**
 * The following method is required for Java snippet support. Do not remove.
 * @generated (com.ibm.wbit.java)
 */
public DataObject execute(DataObject input1) {
  // covert input1 to ServiceMessageObject type
  ServiceMessageObject smo = (ServiceMessageObject) input1;
  
  // get headers in the SMO
  HeadersType headers = smo.getHeaders();
  
  // get SOAP header element
  if (headers.getSOAPHeader().size() > 0) {
    SOAPHeaderType soapHeader = (SOAPHeaderType) headers.getSOAPHeader().get(0);
    DataObject soapHeaderDO = (DataObject) soapHeader.getValue();
    System.out.println(OutputHelper.print(soapHeaderDO));

    // get priority
    int priority = soapHeaderDO.getInt("priority");
    System.out.println("Priority in SOAP Header: " + priority);

    // create a new JMSHeaderType
    JMSHeaderType jmsHeader = ServiceMessageObjectFactory.eINSTANCE.
        createJMSHeaderType();
    jmsHeader.setJMSPriority(BigInteger.valueOf(priority));
    
    // set JMS header element
    headers.setJMSHeader(jmsHeader);
    
    // delete SOAP header
    smo.getHeaders().getSOAPHeader().remove(0);
  }
  
  return (DataObject) smo;
}
      

public void onMessage(javax.jms.Message msg) {
  try {
    System.out.println("Enter MDB ...");
    
    // print the value of JMSPriority 
    System.out.println("JMSPriority is: " + msg.getJMSPriority());
    
    // get payload of the JMS message
    String payload = ((TextMessage) msg).getText();
    
    // get message id of the JMS message
    String MessageID = msg.getJMSMessageID();
    
    // get JMS resources to return the response message
    InitialContext context = new InitialContext();
    Queue q = (Queue) context.lookup("java:comp/env/test/sender");
    QueueConnectionFactory qcf = (QueueConnectionFactory) context.
        lookup("java:comp/env/test/QCF");
    QueueConnection conn = qcf.createQueueConnection();
    conn.start();
    QueueSession session = conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    QueueSender sender = session.createSender(q);
    
    // create the response message with the same payload as the request message
    TextMessage sendMsg = session.createTextMessage(payload);
    
    // set JMSCorrelationID of the response message to correlate with the request message
    sendMsg.setJMSCorrelationID(MessageID);
    
    // send the response message
    sender.send(sendMsg);
    
    // release the JMS resources
    sender.close();
    session.close();
    conn.close();
    
    System.out.println("Exit MDB ...");
  } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
  }
}
      

public boolean handleRequest(MessageContext context) {
  // Fill in method body or delete method to use GenericHandler
  System.out.println("handler ...");

  SOAPMessageContext soapContext = (SOAPMessageContext) context;
  try {
    SOAPHeader header = soapContext.getMessage().getSOAPPart()
        .getEnvelope().getHeader();
    // add HeaderType element
    SOAPElement header1 = header.addChildElement("HeaderType", "header",
        "http://HeaderMedModule");
    // add priority element
    SOAPElement header2 = header1.addChildElement("priority");
    // add value of the priority
    header2.addTextNode("2");
  } catch (SOAPException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
  }

  return true;
}
      

<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
  xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/"
  xmlns:xsd="http://www.w3.org/2001/XMLSchema"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
  <soapenv:Header>
    <header:HeaderType xmlns:header="http://HeaderMedModule">
      <priority>2</priority>
    </header:HeaderType>
  </soapenv:Header>
  <soapenv:Body>
    <p448:operation1 xmlns:p448="http://HeaderMedModule/HeaderMedInterface">
      <InputPara>
        <payload>aaa</payload>
      </InputPara>
    </p448:operation1>
  </soapenv:Body>
</soapenv:Envelope>
      

[07-1-22 17:39:24:906 CST] 00000069 SystemOut     O (DataObject: HeaderType) {
  priority=(Data)'2'
}
[07-1-22 17:39:24:906 CST] 00000069 SystemOut     O Priority in SOAP Header: 2
[07-1-22 17:39:25:000 CST] 00000096 SystemOut     O Enter MDB ...
[07-1-22 17:39:25:000 CST] 00000096 SystemOut     O JMSPriority is: 2