WebSphere MQ Suite Get Message Service

Implementing the WebSphere MQ Suite Get Message Service

There are no steps required for implementing this service. The default configuration, WSMQ_GetMessage, is ready for use as soon as Sterling B2B Integrator is installed. However, you can edit the service's parameter settings for specific business processes in the GPM.

Setting Up the Service in the GPM

Use the field definitions in the following table to set up the service configuration in the GPM:

<operation name="GET message(s)">
 <participant name="WSMQ_GetMessage"/>
  <output message="toService">
   <assign to="wsmq_metadata1">4095</assign>
   <assign to="wsmq_metadata2">4095</assign>
   <assign to="wsmq_qname">qname</assign>
   <assign to="wsmq_type">BROWSEALL</assign>
   <assign to="wsmq_MQGMO_syncpoint">No</assign>
   <assign to="wsmq_rcvMsgLimit">3</assign>
   <assign to="wsmq_sessionid" from="string(wsmq_sessionid)">
   </assign>
  </output>
  <input message="fromService">
   <assign to="." from="*"></assign>
  </input> 
</operation>

Process Data Example

The following example illustrates how process data would look if you specified the value 4095 for the parameters wsmq_metadata1 and wsmq_metadata2. (4095 is the sum of all the available values for the metadata fields: 1+2+4+8+16+32+64+128+256+512+1024+2048 = 4095):

<ProcessData> 
 <WSMQ> 
    <DocumentCount>1</documentCount> 
   <Document1 SCIObjectID="df8f5e:102fa5a6c8f:-7414"> 
     <messageId>414D5120514D5F6761727931303030205D624C4220000502</messageId> 
     <correlationId>000000000000000000000000000000000000000000000000
     </correlationId> 
     <groupId>000000000000000000000000000000000000000000000000</groupId> 
     <accountingToken>16010515000000B5E512BBA14EC030000000000000000B
     </accountingToken> 
     <replyToQueueManagerName>QM_test1000</replyToQueueManagerName>
      <replyToQueueName/> 
     <applicationIdData/> 
      <applicationOriginData/> 
     <messageType verbose="Datagram">8</messageType> 
     <format>MQSTR   </format> 
     <report>0</report> 
      <feedback>0</feedback> 
     <groupStatus/> 
      <encoding>273</encoding> 
     <characterSet>819</characterSet> 
     <expiry>-1</expiry> 
      <putDateTime>03-31-2005 15:58:18</putDateTime> 
      <putApplicationName>MQSeries Client for Java </putApplicationName> 
     <putApplicationType>28</putApplicationType> 
     <messageFlags>0</messageFlags> 
     <messageSequenceNumber>1</messageSequenceNumber> 
     <offset>0</offset> 
      <persistence>0</persistence> 
     <priority>0</priority> 
    </Document1> 
 </WSMQ> 
</ProcessData> 

Parameters Passed From Service to Business Process

The following table contains the parameters passed from the WebSphere MQ Suite Get Message service to the business process:

Parameters Passed From Business Process to Service

The following table contains the parameters passed from the business process to the WebSphere MQ Suite Get Message service:

Business Process Example

The following example illustrates how the WebSphere MQ Suite Get Message service can be used in a business process:

<process name = "GETexample">  
  <sequence name="OpenSession"> 
   <operation name="Open Session"> 
     <participant name="WSMQ_OpenSession"/> 
     <output message="toService"> 
       <assign to="." from="*"/> 
        <assign to="wsmq_hostname">some_host_name</assign> 
       <assign to="wsmq_channel">some_channel_name</assign> 
       <!-- <assign to="wsmq_debug">Yes</assign> --> 
     </output> 
      <input message="fromService"> 
       <assign to="." from="*"/> 
     </input> 
    </operation> 
 
   <sequence name="SessionOpened"> 
     <operation name="Open Queue"> 
       <participant name="WSMQ_OpenQueue"/> 
       <output message="toService"> 
         <assign to="wsmq_sessionid" from="string(wsmq_sessionid)"/> 
         <assign to="wsmq_qname">some_queue_name</assign> 
         <assign to="wsmq_MQOO_type">PUT</assign> 
         <assign to="wsmq_MQOO_failifquiescing">Yes</assign> 
       </output> 
        <input message="fromService"/> 
     </operation> 
 
     <operation name="GET message(s)"> 
       <participant name="WSMQ_GetMessage"/> 
       <output message="toService"> 
         <assign to="wsmq_sessionid" from="string(wsmq_sessionid)"/> 
         <assign to="wsmq_qname" from="some_queue_name"/> 
         <assign to="wsmq_metadata1">4095</assign> 
         <assign to="wsmq_metadata2">4095</assign> 
         <assign to="wsmq_type">GETALL</assign> 
       </output> 
        <input message="fromService"> 
         <assign to="." from="*"/> 
       </input> 
      </operation> 
 
     <operation name="Commit the GET"> 
       <participant name="WSMQ_Commit"/> 
       <output message="toService"> 
         <assign to="wsmq_sessionid" from="string(wsmq_sessionid)"/> 
       </output> 
        <input message="fromService"/> 
     </operation> 
 
     <operation name="Close Queue"> 
       <participant name="WSMQ_CloseQueue"/> 
       <output message="toService"> 
         <assign to="wsmq_sessionid" from="string(wsmq_sessionid)"/> 
         <assign to="wsmq_qname">some_queue_name</assign> 
       </output> 
        <input message="fromService"/> 
     </operation> 
 
     <sequence name="CloseSession"> 
       <operation name="Close Session"> 
         <participant name="WSMQ_CloseSession"/> 
         <output message="toService"> 
           <assign to="." from="*"/> <!—wsmq_sessionid passed by default --> 
          </output> 
         <input message="fromService"/> 
       </operation> 
      </sequence> 
 
     <onFault> 
        <operation name="Make sure session is closed"> 
          <participant name="WSMQ_CloseSession"/> 
          <output message="toService"> 
            <assign to="wsmq_sessionid" from="string(wsmq_sessionid)"/> 
         </output> 
          <input message="fromService"/> 
        </operation> 
     </onFault> 
    </sequence> <!-- end of SessionOpened sequence --> 
  </sequence> <!-- end of OpenSession sequence --> 
</process>