ITPub博客

Requester.java源码：import com.ibm.mq.*;public class Requester { public static void main(String args[]) { try { String hostName = "127.0.0.1"; String channel = "CHAN1"; String qManager = "QM1"; String requestQueue = "QL1"; String replyToQueue = "REPLYQ"; String replyToQueueManager = "QM1"; // Set up the MQEnvironment properties for Client Connections MQEnvironment.hostname = hostName; MQEnvironment.channel = channel;

MQTrigger.java源码如下：import java.io.*;import java.lang.*;import com.ibm.mq.*;class MQTrigger{ private String structId; private String version; private String qName; private String processName; private String triggerData; private String applType; private String applId; private String envData; private String userData; private String qMgrName; /******************************************************/ /* Constructor to parse the MQTMC2 stucture and set */ /* the class a

首先做如下配置定义：Use runmqsc to create the following objects: 1. Queue to be triggered. DEFINE QLOCAL('JAVA.TRIGGER.QUEUE') REPLACE + DESCR('Application queue to test triggering') + SHARE + TRIGGER + TRIGTYPE (FIRST) + INITQ('JAVA.INIT.QUEUE') + PROCESS('JAVA.PROCESS') 2. Initiation queue. DEFINE QLOCAL('JAVA.INIT.QUEUE') REPLACE + DESCR('Initiation queue to test triggering') 3. Process. ** DEFINE PROCESS('JAVA.PROCESS') REPLACE + DESCR('Process to test triggering') + APPLICID('java -cp .;c:m

源码：import java.util.Hashtable; import javax.jms.*; import javax.naming.*; import javax.naming.directory.*; public class sample { protected QueueConnectionFactory factory=null; protected QueueConnection connection; protected QueueSession queueSession; protected TextMessage outMessage; protected QueueSender queueSender; protected QueueReceiver queueReceiver; public static final String qcfLookup="QCFC"; public static final String qLookup="Q1"; public static final S