在 Java 程序中在 IBM MQ 中创建主题
Posted
技术标签:
【中文标题】在 Java 程序中在 IBM MQ 中创建主题【英文标题】:Create a topic in IBM MQ in java program 【发布时间】:2015-06-28 17:56:04 【问题描述】:我想在我的 Java 应用程序中创建一个名为“manipulation”的主题,但我收到此错误:
Exception in thread "main" com.ibm.mq.MQException: MQJE001: Completion Code '2', Reason '2085'
我的代码是:
MQTopic subscriber = new MQTopic(queueManager, null, "manipulation",CMQC.MQTOPIC_OPEN_AS_SUBSCRIPTION, CMQC.MQSO_CREATE);
如这里所说:
Accessing queues, topics, and processes in IBM MQ classes for Java
【问题讨论】:
【参考方案1】:您用于创建主题订阅的代码需要稍作修改才能使其正常工作:
MQTopic subscriber = new MQTopic(queueManager, null, "manipulation",CMQC.MQTOPIC_OPEN_AS_SUBSCRIPTION, CMQC.MQSO_CREATE);
在上面的 sn-p 中你已经指定了第三个参数,即主题对象名称。当您指定主题对象名称时,该对象必须存在才能使用。在您的情况下,您已经以管理方式创建了一个名为 manipulation
的主题对象,然后使用上面的构造函数创建订阅。因为主题manipulation
不存在,所以抛出了MQRC 2085
异常。
你有两个选择:
1) 以管理方式创建主题对象“操作”。
2) 如果您不想创建主题对象,请在不使用主题对象名称的情况下即时创建订阅,如下所示
MQTopic subscriber = queueManager.accessTopic("manipulation", "", CMQC.MQTOPIC_OPEN_AS_SUBSCRIPTION, CMQC.MQSO_MANAGED | CMQC.MQSO_CREATE | CMQC.MQOO_FAIL_IF_QUIESCING);
【讨论】:
【参考方案2】:MQ 异常 2085 表示 MQRC_UNKNOWN_OBJECT_NAME
您提供的队列对象名称无效。
示例代码:
try
MQTopicConnectionFactory cf = new MQTopicConnectionFactory();
// Config
cf.setHostName("<Destination-IP>");
cf.setPort(1414);
cf.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
cf.setQueueManager("<Queue-Manager-Name>");
cf.setChannel("SYSTEM.DEF.SVRCONN");
MQTopicConnection connection = (MQTopicConnection) cf.createTopicConnection();
MQTopicSession session = (MQTopicSession) connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
MQTopic topic = (MQTopic) session.createTopic("topic://test");
MQTopicPublisher publisher = (MQTopicPublisher) session.createPublisher(topic);
MQTopicSubscriber subscriber = (MQTopicSubscriber) session.createSubscriber(topic);
JMSTextMessage message = (JMSTextMessage) session.createTextMessage("Hello World");
// Start the connection
connection.start();
publisher.publish(message);
log.info("Sent message:" + message);
JMSMessage receivedMessage = (JMSMessage) subscriber.receive(10000);
log.info("Received message:" + receivedMessage);
publisher.close();
subscriber.close();
session.close();
connection.close();
log.info("SUCCESS");
catch (JMSException jex)
log.error(jex.getMessage());
catch (Exception ex)
log.error(ex.getMessage());
System.out.println("\\nFAILURE\\n");
您也可以在命令提示符下执行相同操作
crtmqm QM_A //Create Queue-Manager
strmqm QM_A //Start Queue-Manager
runmqsc QM_A //Open Websphere MQ CLI
DEFINE LISTENER(A.LISTENER) TRPTYPE(TCP) CONTROL(QMGR) PORT(1414) //Define Listener
START LISTENER(A.LISTENER) //Start Listener
DEFINE CHANNEL(A.CHANNEL) CHLTYPE(SVRCONN) //Define Channel
START CHANNEL(A.CHANNEL) // Start Channel
DEFINE QLOCAL(A.QUEUE) MAXDEPTH(50000) //Define LocalQueue
DEFINE TOPIC(A.TOPIC) TOPICSTR('A') //Define Topic
DEFINE SUB(A.SUBQUEUE) DEST(A.QUEUE) TOPICOBJ(A.TOPIC) REPLACE; //Link Subscription Queue with Topic
访问http://bencane.com/2013/04/22/websphere-mq-cheat-sheet-for-system-administrators/
【讨论】:
以上是关于在 Java 程序中在 IBM MQ 中创建主题的主要内容,如果未能解决你的问题,请参考以下文章