MQSeries.net :: View topic

saurabh.mk2003 · Posted: Sat Jun 02, 2007 3:01 am Post subject:

My program requirement is that I should be able to browse the messages in the Websphere Message Queue (MQ) through pure Java code for which I have written the following code :

/*Function:
This program browses message before actually getting them.
java mqbrowse ORDER_IN */
// C:\Progra~1\Java\jdk1.6.0_01\bin\java.exe

import com.ibm.mq.*;
import java.io.*;
import java.lang.*;

public class mqbrowse
{
private MQQueueManager qMgr;

public static void main (String args[]) throws IOException
{
if (args.length < 1)
{
System.out.println("Required parameter missing - queue name");
}
else
{
System.out.println("mqbrowse: Browse and optionally get messages");
mqbrowse mySample = new mqbrowse();

mySample.start(args);
}
System.exit(0);
}

public void start(String args[])
{
try
{
if (args.length > 1)
{

qMgr = new MQQueueManager(args[1]); //Create a connection to the queue manager.

}
else
{

qMgr = new MQQueueManager("QM"); //If the queue manager name is left blank (null or ""), a connection is made to the default queue manager
}
int openOptions = MQC.MQOO_INPUT_EXCLUSIVE | MQC.MQOO_BROWSE;
//Open to get messages with exclusive access //Open to browse message.

// MQQueue myQueue = qMgr.accessQueue(args[0], openOptions,null, null, null);
MQQueue myQueue = qMgr.accessQueue("ORDER_IN", openOptions,"QM", null, null);
//Establishes access to a WebSphere MQ queue on this queue manager to get or browse messages,

InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);

String runShow;

MQGetMessageOptions gmo = new MQGetMessageOptions();

gmo.options = MQC.MQGMO_BROWSE_FIRST; //MQC.MQGMO_WAIT |
//Browse from start of queue.

MQMessage myMessage = new MQMessage();

boolean done = true; //boolean done = false;
do
{
try
{
myMessage.clearMessage();
// myMessage.correlationId = MQC.MQCI_NONE;
// myMessage.messageId = MQC.MQMI_NONE;

myQueue.get(myMessage, gmo);

String msg = myMessage.readString(myMessage.getMessageLength());

System.out.println("Browsed message: " + msg);
System.out.println("Actually get message?");
runShow = br.readLine();
if (runShow.length() > 0)
{
if ((runShow.indexOf("Y") != -1)|| (runShow.indexOf("y") != -1))
{
System.out.println("Actually getting the message");
gmo.options = MQC.MQGMO_MSG_UNDER_CURSOR;
myQueue.get(myMessage, gmo);
}
}

gmo.options = MQC.MQGMO_WAIT | MQC.MQGMO_BROWSE_NEXT;

}catch (MQException ex)
{

//System.out.println("MQ exception: CC = " + ex.completionCode
// + " RC = " + ex.reasonCode);

done = true;
}
catch (java.io.IOException ex)
{
// System.out.println("Java exception: " + ex);
done = true;

}

} while (!done);

myQueue.close();
qMgr.disconnect();
}
catch (MQException ex)
{
//System.out.println("MQ exception: CC = " + ex.completionCode
// + " RC = " + ex.reasonCode);

}
}
}

While compiling & running the code as posted above, its not giving any problem. Its working fine.But on the console its giving me the MQ exception as:

MQJE001: Completion Code 2, Reason 2058

When I searched for this exception in Google, it states that that the Queue Manager is not connected, even though I have started the Queue Manager.
So through the same java code how can I ensure that the connection is made properly to the Queue Manager? and through which API?