MQSeries.net :: View topic

justrob · Posted: Fri Sep 02, 2005 9:23 am Post subject:

We have a problem... lots of 2009 errors (yet the channels remain running), and svrconn channels that just hang around, and keep increasing. As they increase, they increase the amqcrsta processes (hp ux 10) and eventually kill the system.

Here's the kicker, its' a V2.2.1 server with a V5.3 client connecting.
Is there anything short of upgrading that can help here? (upgrading at this point is not an option)

Thanks

import com.ibm.mq.* ;

/**
* This test program receives messages from MQ input queue INQ, and
* sends response to OUTQ.
*/

public class Responder {
public static void main(String args[]) {
MQQueue respQueue = null;
MQQueue queue = null;
MQQueueManager qMgr = null ;

//test return values
String[] retVal = {
"2#999#Could Not find MailBox on MOD", "1#0#", "1#0#",
"2#999#Could Not find MailBox on MOD","1#0#", "1#0# ",
"2#999#Unexpected Action received from SSM","1#0#", "1#0#"
};
try
{
String hostName = "198.105.214.2" ;
String channel = "MQMCHAN" ;
String qManager = "MQPV" ;
String qName = "INQ" ;
String replyName = "OUTQ" ;

//Set up the MQEnvironment properties for Client Connections
MQEnvironment.hostname = hostName ;
MQEnvironment.channel = channel ;
MQEnvironment.port = 1414 ;
MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
MQC.TRANSPORT_MQSERIES);

//Connection To the Queue Manager
qMgr = new MQQueueManager(qManager) ;

/* Set up the open options to open the queue for out put and
additionally we have set the option to fail if the queue manager is
quiescing.
*/
int openOptions = MQC.MQOO_INPUT_SHARED | MQC.MQOO_FAIL_IF_QUIESCING ;

//Open the queue
queue = qMgr.accessQueue(qName,
openOptions,
null,
null,
null);
System.out.println("Ready for receiving responses...");

// Set the put message options.
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options = gmo.options + MQC.MQGMO_SYNCPOINT ; //Get messages unde sync point control
gmo.options = gmo.options + MQC.MQGMO_WAIT ; // Wait if no messages on the Queue
gmo.waitInterval = MQC.MQWI_UNLIMITED ; // Sets the time limit for the wait.

/* Next we Build a message The MQMessage class encapsulates the data buffer
that contains the actual message data, together with all the MQMD
parameters that describe the message.
To Build a new message, create a new instance of MQMessage class and use
writxxx (we will be using writeString method). The put() method of
MQQueue also takes an instance of the MQPutMessageOptions class as a parameter.
*/

int count = 0;
for(;

{

MQMessage inMsg = new MQMessage(); //Create the message buffer
// Get the message from the queue on to the message buffer.

queue.get(inMsg, gmo) ;
qMgr.commit();

String msgString = inMsg.readString(inMsg.getMessageLength());
System.out.println(" The Message from the Queue is : " + msgString);

System.out.println("Preparing To Reply To the Request " );
openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING ;
respQueue = qMgr.accessQueue(replyName,
openOptions,
null,
null,
null);
MQMessage respMessage = new MQMessage() ;
respMessage.correlationId = inMsg.messageId;

MQPutMessageOptions pmo = new MQPutMessageOptions();

pmo.options = pmo.options + MQC.MQPMO_SYNCPOINT ;
respMessage.format = MQC.MQFMT_STRING ;

String response = "Reply from the Responder Program " ;

msgString = msgString + ":" + retVal[count];
count++;

respMessage.writeString(msgString);
respQueue.put(respMessage, pmo);
System.out.println("The response Successfully send: " + msgString );
qMgr.commit();
respQueue.close();
}
} catch (MQException ex) {
System.out.println("An MQ Error Occurred: Completion Code is :\t" +
ex.completionCode + "\n\n The Reason Code is :\t" + ex.reasonCode );
ex.printStackTrace();
} catch(Exception e) {
e.printStackTrace();
} finally {
try {
if(queue != null) queue.close();
if(respQueue != null) respQueue.close();
if(qMgr != null) qMgr.disconnect();
} catch (Exception ex) {}
}
}
}