MQSeries.net :: View topic

garonne · Posted: Wed Mar 22, 2006 7:51 pm Post subject:

I have a program client of contact admin. In the JNDI context of contact admin, I have all the WebSphere MQ ConnectionFactory objects. My program try to receive messages from a MQ topic through these ConnectionFactory objects.
When I do:
Session session = tc.createSession(false, Session.AUTO_ACKNOWLEDGE);
or
Session session = tc.createSession(true, Session.AUTO_ACKNOWLEDGE);
It work! I can receive message

But It doesn't work when I do
Session session = tc.createXATopicSession();
and I receive no message, I don't see any exception

So, have anyone please explain this problem. Thanks alot!

Here is the code of my program:

// MsgReceptor.java
// JMS client program that will receive the messages published on the Topic
// by the EJB component
package jms;

import javax.jms.XATopicConnection;
import javax.jms.XATopicConnectionFactory;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class MsgReceptor {

//JNDI Context of contact admin Application Server
private static Context ictx = null;

private static XATopicConnectionFactory cf = null;

private static Topic topic = null;

// JNDI name of the WebSphere MQ connection factory binded in contact admin context
//private static String conFactName = "JCF";

//// JNDI name of the WebSphere MQ xa topic connection factory binded in contact admin context
private static String conFactName = "wsmqXATCF";

// JNDI name of the Topic
private static String topicName = "sampleTopic";

public static void main(String[] arg) {

// Get InitialContext for contact admin
try {
ictx = new InitialContext();
// lookup the TopicConnectionFactory through its JNDI name
cf = (XATopicConnectionFactory) ictx.lookup(conFactName);

System.out.println("JMS client: cf = " + cf.toString());

// lookup the Topic through its JNDI name
topic = (Topic) ictx.lookup(topicName);
System.out.println("JMS Topic topic = " + topic.toString());
} catch (NamingException e) {
e.printStackTrace();
System.exit(2);
}

try {
XATopicConnection tc = cf.createXATopicConnection();
System.out.println("JMS client: tc = " + tc.toString());

// this works!
//Session session = tc.createSession(false, Session.AUTO_ACKNOWLEDGE);

// this works!
Session session = tc.createSession(true, Session.AUTO_ACKNOWLEDGE);

// this DOES NOT work, I see NO EXCEPTION
//Session session = tc.createXATopicSession();

MessageConsumer mc = session.createConsumer(topic);
/* create and set a MessageListener */
MyListenerSimple listener = new MyListenerSimple();
mc.setMessageListener(listener);

System.out.println("JMS client: Waiting for messages ...");
tc.start();

System.in.read();

session.close();
tc.close();
} catch (Exception e) {
System.out.println("Exception in message reception operations");
e.printStackTrace();
}

}
}