MQSeries.net :: View topic

mvoicu · Posted: Thu Oct 25, 2001 8:52 am Post subject:

Hello everyone,

I have a couple of issues that I would like to raise and have your attention.

I have installed a MQSeries 5.2.1 on my W2K machine. I have added the extentions for Pub/Sub (ma0c_ntmq52.exe) and the Java classes. I addition I have setup my environment as per in "MQSseries using Java" Redbook.
On top of these, I have setup a JNDI for my TCF and Topic.

Issues:
1) Running the JMSPubSub.java example from the samples diretory I got an warning:
- unable to load message catalog - mqji
Am I missing something on my environment?

2) The same example has been change to allow to publish a message 1000 times by adding the following code:
...
msg = tSess.createTextMessage();
System.out.print( "Text to publish : " );
String payload = in.readLine();
msg.setText(payload);
// ...and publish it
for(int i=0; i<1000; i++){
tPub.publish(msg);
System.out.println("Sending message#"+i);
Thread.sleep(500);
};
break;

In the same way the subscriber section has been changed to reflect the receiving of the same amount of messages.
So far, compiling and running on two prompts , I haven't seen any problems.
Now, start a couple more command prompts and run a subscriber on each of them. As a result, you are going to see is that the subscribers will receive the messages. AFTER A WHILE , start one more subscriber, as you've done before, and SURPRISE, the previous started subscribers WILL STOP receiving messages without any errors or warnings.
Could anyone explaine this to me or give me an advise on what is going on?

Thx,
Mihai

[ This Message was edited by: mvoicu on 2001-10-25 10:02 ]