当我使用此代码为订户:如何在IBM MQ集群中实时创建订阅?
MQTopic QMsSubscription = qm.accessTopic("qmstop", "", CMQC.MQTOPIC_OPEN_AS_SUBSCRIPTION, CMQC.MQSO_CREATE);
MQMessage recvQMsMsg = new MQMessage();
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options = MQConstants.MQGMO_WAIT;
gmo.waitInterval = MQConstants.MQWI_UNLIMITED;
QMsSubscription.get(recvQMsMsg, gmo);
和此代码为出版商:
MQTopic QMsPublisher = qm.accessTopic("qmstop", "", CMQC.MQTOPIC_OPEN_AS_PUBLICATION, CMQC.MQOO_OUTPUT);
MQMessage sendQMsMsg = new MQMessage();
sendQMsMsg.writeString(thisQM);
QMsPublisher.put(sendQMsMsg);
这些代码工作以及在一台机器与一个队列管理器,但是当我在集群中使用这些代码与许多队列管理器消息不发送到其他机器。
如何在集群中实时创建主题字符串?
您需要告诉WMQ该主题应该是类型集群。但这并不是“即时”。 http://www-01.ibm.com/support/docview.wss?uid=swg27016146#3 –