MQSeries.net :: View topic - JMS Pub-Sub Problem

hllam · Posted: Tue Jul 04, 2006 9:47 am Post subject:

We are now using MQSeries v5.3 + SupportPac MQ_CSD08

We try to integrade MQ by JMS, However, in JMS specification, it assumed that referencing objects should be created by underlaying MOM server( which is MQSeries in our case).

For the P2P communication, we can create the physical Queue in MQ, by invoke runmqsc using JAVA Runtime class.
i.e.
echo DEFINE QLOCAL('Queue') REPLACE DEFPSIST(YET) SHARE | c:\Progra~1\IBM\WebSph~2\bin\runmqsc QM_RAE

And we can define MQ object name in JNDI by JMSAdmin.exe <---- It seems only define a namespace but not a physical object.

However, for the Pub-Sub communication mode, we can't find the way to create a Topic.
In MQ, it does not have a physical "Topic" object. It seems a pub-sub broker is used to simulate a Topic connection with a Queue object.
So we want to know how to config and link the logical "Topic" with a physical "Queue".

To config the Pub-Sub in MQ :

First, we have setup a QManager "QM_RAE" and created all the required system queue using the startup script :
i.e.
\bin\runmqsc QM_RAE < MQJMS_PSQ.mqsc

and then linked it with a topic broker,
i.e.
strmqbrk -m QM_RAE

We can run the predefined verification script without error
i.e.
psivtrun -nojndi -m QM_RAE

But when we try to dynamic create Topic in programming level, we got the JMSException, saying that underlaying queue is not
created or not available :

javax.jms.JMSException: MQJMS2008: failed to open MQ queue
at com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironment.java:530)
at com.ibm.mq.jms.MQTopicSession.createPublisher(MQTopicSession.java:898)
at TestMQ_PS.<init>(TestMQ_PS.java:58)
at TestMQ_PS.main(TestMQ_PS.java:171)

the corresponding linked Exception in MQ is :

com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2085
at com.ibm.mq.MQQueueManager.accessQueue(MQQueueManager.java:1391)
at com.ibm.mq.jms.MQTopicSession.createPublisher(MQTopicSession.java:893)
at TestMQ_PS.<init>(TestMQ_PS.java:58)
at TestMQ_PS.main(TestMQ_PS.java:171)

The meaning of reason code 2085 is :

2085 0x00000825 MQRC_UNKNOWN_OBJECT_NAME

The code we used for testing, is the standard MQ JMS sample code :

factory = new MQTopicConnectionFactory();
factory.setHostName(hostname);
factory.setPort(port);
factory.setQueueManager(qMgrName);
factory.setBrokerQueueManager(qMgrName);
factory.setBrokerControlQueue("BROKER.CONTROL.QUEUE");
factory.setBrokerPubQueue("BROKER.DEFAULT.STREAM");

// createQueue(QUEUE);

topicConnection = factory.createTopicConnection();
topicConnection.start();
topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);

Topic topic = topicSession.createTopic("topic://NEWSTOPIC1?brokerVersion=1");
TopicPublisher publisher = topicSession.createPublisher(topic);
TopicSubscriber subscriber = topicSession.createSubscriber(topic);

TextMessage message = topicSession.createTextMessage();
message.setText("Hello subscribers..");
publisher.publish(message);

TextMessage inMessage = (TextMessage)subscriber.receive();
System.out.println(inMessage.getText());

publisher.close();
subscriber.close();
topicSession.close();
pubSession.close();
topicConnection.close();