MQSeries.net :: View topic

tqtuan · Posted: Sat Nov 22, 2003 4:26 pm Post subject: new MQQueueManager(...) hangs

Hi,

My application accesses the queue using MQQueueManager(...) to send messages. After awhile, MQ goes down and any attempts to send to the queue throws an exception. When the exception is thrown, I try to recreate the MQQueueManager(...) so that I can access the queue, but the statement "new MQQueueManager(...)" never return. Can someone tell me why, please?

below is the code:

Code:

//set msg options
pmo = new MQPutMessageOptions();
pmo.options = MQC.MQPMO_SET_IDENTITY_CONTEXT;

//set up MQEnvironment
MQEnvironment.channel = channelName;
MQEnvironment.hostname = hostName;
MQEnvironment.port = port;
MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
MQC.TRANSPORT_MQSERIES);
MQEnvironment.disableTracing();

while (error){
try {
//create queue manager
MQQueueManager queueManager = new MQQueueManager(queueManagerName); //It hangs here when the loop repeats
//access queue
MQQueue outQueue = queueManager.accessQueue(
queuename,
s_OPENQUEUEOPTIONS,
null, // default q manager
null, // no dynamic q name
null); // no alternate user id
MQMessage mqm = new MQMessage();
....code to set message
outQueue.put(mqm, pmo);
outQueue.close();
queueManager.disconnect();
break;
}
catch (....){
continue;
}
}