MQSeries.net :: View topic

sharan_nag · Posted: Thu Oct 26, 2006 2:45 am Post subject:

Hi,
I have written a code to read message from the Queue. I am working in HP-UX environment. My Java code is as follows.

import javax.jms.*;
import javax.naming.*;
import java.util.Properties;
import com.ibm.mq.*;
public class SimpleQueueReceiver
{

public static void main(String[] args)
{
String queueName = null;
Context jndiContext = null;
QueueConnectionFactory queueConnectionFactory = null;
QueueConnection queueConnection = null;
QueueSession queueSession = null;
Queue queue = null;
QueueReceiver queueReceiver = null;
TextMessage message = null;

queueName = new String(args[0]);
System.out.println("Queue name is " + queueName);

//Create a JNDI API InitialContext object if none exists yet.
try
{
Properties prop = new Properties();
prop.put(Context.PROVIDER_URL,"file:/opt/mqm/java");
prop.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.jndi.fscontext.RefFSContextFactory");
jndiContext = new InitialContext(prop);
}
catch (NamingException e)
{
System.out.println("Could not create JNDI API context: " + e.toString());
System.exit(1);
}
System.out.println("Created the JNDI API context");

try
{
queueConnectionFactory=(QueueConnectionFactory)jndiContext.lookup("QueueConnectionFactory");
queue=(Queue)jndiContext.lookup(queueName);
}
catch (NamingException e)
{
System.out.println("JNDI API lookup failed: " +e.toString());
System.exit(1);
}
System.out.println("JNDI API lookup successful");

try
{
queueConnection = queueConnectionFactory.createQueueConnection("user","password");
//queueConnection = queueConnectionFactory.createQueueConnection();
System.out.println("QueueConnection created successfully");
queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
System.out.println("QueueSession created successfully");
//queueSession = queueConnection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
queueReceiver = queueSession.createReceiver(queue);
System.out.println("Queue Receiver created successfully");
queueConnection.start();
System.out.println("QueueConnection started");
while (true)
{
Message m = queueReceiver.receive(1);
if (m != null)
{
if (m instanceof TextMessage)
{
message = (TextMessage) m;
System.out.println("Reading message: " +message.getText());
}
else
{
break;
}
}
}
}
catch (JMSException e)
{
System.out.println("Exception occurred: " +e.toString());
Exception ex = e.getLinkedException();
if(ex!=null)
System.out.println("Linked Exception is : "+ex);
}
finally
{
if (queueConnection != null)
{
try
{
queueConnection.close();
}
catch (JMSException e) {}
}
}
}
}

I am getting the following exception when i run the above java code.

Exception occurred: javax.jms.JMSSecurityException: MQJMS2008: failed to open MQ queue
Linked Exception : com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2035

Can you please suggest me what to do ?
Thanks in advance.

Thanks and Regards,
Sharanu A N