2006-09-08
IBM MQ example:
package com.bulain.wasmq;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import com.ibm.mq.jms.JMSC;
import com.ibm.mq.jms.MQQueueConnectionFactory;
public class CreateMq implements MessageListener {
private String qName = "clq_default_mphch085";
private String HOSTNAME = "10.240.13.81";
private String QMGRNAME = "QM_mphch085";
private String CHANNEL = "S_mphch085";
private Integer PORTINT = new Integer(1414);
private String CLIENTID = "";
private Integer CCSID = new Integer(932);
private String username="mqadmin";
private String password="";
private QueueConnection qConnection = null;
private QueueSession qSession = null;
private Queue ioQueue;
private QueueSender sender;
private QueueReceiver receiver;
public static void main(String[] args) throws JMSException {
CreateMq mq = new CreateMq();
mq.testMQ();
}
public void testMQ() throws JMSException{
makeQueueConnection();
createSender();
sendMessage("This is a test");
createReceiver();
//disconnect();
}
public void makeQueueConnection() {
try {
// Create a Queue Connection Factory & set its properties
MQQueueConnectionFactory factory = new MQQueueConnectionFactory();
factory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
factory.setQueueManager(QMGRNAME);
factory.setHostName(HOSTNAME);
factory.setChannel(CHANNEL);
factory.setPort(PORTINT.intValue());
if (CCSID != null && CCSID.intValue() > 0) {
factory.setCCSID(CCSID.intValue());
}
// Create a Connection
qConnection = factory.createQueueConnection(username,password);
// The client identifier is ignored for point to point connections. Since
// we are using point to point connections, there is no need to set the ClientID.
qConnection.setClientID( CLIENTID );
qConnection.start();
// Create a Session
boolean transacted = false;
qSession = qConnection.createQueueSession(transacted, Session.AUTO_ACKNOWLEDGE);
// Create a Queue
String QUEUENAME = qName;
// String queueParam = "queue://" + QMGRNAME + "/" + QUEUENAME + "?targetClient=1";
// AIUJP : ADD THE CCSID in the queue paramater
// queueParam = "queue://" + QMGRNAME + "/" + QUEUENAME + "?targetClient=1&CCSID="+CCSID.intValue();
String queueParam = buildQueueParam(QMGRNAME, QUEUENAME);
ioQueue = qSession.createQueue(queueParam);
} catch (Exception e) {
}
}
private String buildQueueParam(String qMgr, String qName) {
String queueParam = null;
if (qMgr == null || (qMgr != null && qMgr.trim().length() <= 0)) {
return queueParam;
}
if (qName == null || (qName != null && qName.trim().length() <= 0)) {
return queueParam;
}
queueParam = "queue://" + qMgr + "/" + qName + "?targetClient=1";
if (CCSID != null && CCSID.intValue() != 0) {
queueParam += "&CCSID=" + CCSID.intValue();
}
return queueParam;
}
public void createReceiver() throws JMSException{
receiver = qSession.createReceiver(ioQueue);
receiver.setMessageListener(this);
qConnection.start();
}
public void createSender() throws JMSException{
sender = qSession.createSender(ioQueue);
}
public void sendMessage(String message) throws JMSException{
Message msg = qSession.createTextMessage(message);
sender.send(msg);
}
public void onMessage(Message message) {
try {
TextMessage tMessage = (TextMessage) message;
String text;
text = tMessage.getText();
System.out.println("Received message <" + text + "> with ID <" + message.getJMSMessageID() + ">");
} catch (JMSException e) {
e.printStackTrace();
}
}
public void disconnect() throws JMSException {
receiver.close();
qSession.close();
qConnection.stop();
qConnection.close();
System.out.println("Receiver stopped.");
}
}
分享到:
相关推荐
A IBM MQ client is part of the product that can be installed on its own, on a separate machine from the base product and server. You can run an IBM MQ application on an IBM MQ client and it can ...
Java连接IBM WebSphere MQ 7处理队列信息所需jar包,从安装目录直接打的包。主要包括: /com.ibm.mq.commonservices.jar /com.ibm.mq.defaultconfig.jar /com.ibm.mq.fta.jar /com.ibm.mq.headers.jar /...
下载后解压即可使用,专门测试远程和本地IBMMQ数据,可以导入导出数据
jmeter插件,用于进行IBM MQ测试。 部署插件之后,可进行简单配置,即可发送消息到mq通道中 使用方法参见 https://testerhome.com/notes/2193
JAVA连接IBM MQ,具体的详细说明,请再csdn上面搜索JAVA连接IBM MQ关键词
ibmmq所需jar包,用于ibmmq连接建立,消息发送与接收,导入这些jar就能完成ibmmq相关功能。
java IBM MQ 7.5.0 生产者和消费者实例
JAVA IBM MQ 接收消息、发送消息例子
一个简单的IBM MQ操作例子,put方法和get方法
ibm mq开发教程.pdf
资源名称:IBM MQ7.5安装配置(Win)内容简介: IBM的MQ网上安装部署的资料比较少见,抽空整理了一个,截图,都图形化的操作界面,适用于初学者。熟悉了以后,就不用图形了,直接敲命令行就可以了。资源截图: 资源太...
IBM MQ将消息发送至远程队列,文档详细,有截图,有命令
Spring 集成 IBM MQ 监听配置,包括用户管理配置和一些基础配置信息
IBM MQ 7.5.0 windows版本全部仅需要一次下载即可使用
java开发ibm mq 7.5对接所需要的jar依赖包,由于maven没有授权,所以必须手动下载
IBM MQ 7.5.0 windows版本压缩包第一部分,共4部分(分割是为了满足平台只能上传110MB文件的要求)。IBM MQ是JMS协议的一个实现,广泛用在系统集成中。
IBM MQ经常被一些政府公共部门,银行等企业用来做数据传输和报文收发,在互联网应用的开发中较少见到,资源为MQjava 代码
MQ频繁出现的错误代码请查看excel文档,如果没有请查看另外一份文档, 有英文和中文。基本上覆盖了MQ所有的问题码。MQ错误码大全,希望对您有所帮助(错误码已排序,方便大家查找,使用)。
ibm-mq里面的com.ibm.mqetclient.jar下载,有需要的可以直接下载,亲自测过可以正常使用。
MQ所需要的九个包下载大全 aspectjrt-1.5.2 com.ibm.mq.fta com.ibm.mq com.ibm.mq.jmqi com.ibm.mq.jms.Nojndi com.ibm.mq.soap com.ibm.mqetclient com.ibm.mqjms connector-1.0