注：IBMMQ的CCSID:1381
package com;
import java.io.EOFException;
import java.io.IOException;
import javax.jms.*;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQQueueManager;
import com.ibm.mq.jms.JMSC;
import com.ibm.mq.MQQueue;
import com.ibm.mq.jms.MQTopicConnectionFactory;
import com.ibm.mq.MQDestination;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.constants.CMQC;
import com.ibm.mq.MQC;
public class Publish {
public MQTopicConnectionFactory
ippsFactory = new MQTopicConnectionFactory();
package com.test.publish;
import javax.jms.*;
import com.ibm.mq.jms.JMSC;
import com.ibm.mq.jms.MQTopicConnectionFactory;
public class Publish {
public MQTopicConnectionFactory
ippsFactory = new MQTopicConnectionFactory();
TopicConnection connection;
TopicSession session;
TopicPublisher publisher;
public void initFactory() throws
JMSException{
ippsFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
// 设置传输类型
ippsFactory.setQueueManager('QM_TEMP');//
配置队列管理器名
ippsFactory.setHostName('192.168.0.1'); // 主机名
IP地址
加载中…
转载▼