MQSeries.net :: View topic - What's the problem of my code ? Got MQJMS1111: JMS1.1

kun.leeing · Posted: Wed Nov 12, 2008 2:12 pm Post subject:

'dspmqbrk -m DefaultQManager' shows running.

//************************My Code***************************

import javax.jms.*;

public class TopicLoad {

private static String qMgrName = "DefaultQManager";
private static String tName = "TopicLoad";

public static void main( String[] args ) throws JMSException {

Object[] adminObjects = new Object[2];
obtainAdminObjects( adminObjects );
TopicConnectionFactory tcf = (TopicConnectionFactory)adminObjects[0];
Topic t = (Topic)adminObjects[1];

TopicConnection conn = tcf.createTopicConnection();
conn.start();

TopicSession sess = conn.createTopicSession( false,
Session.AUTO_ACKNOWLEDGE );
TopicPublisher publisher = sess.createPublisher(t);
TextMessage msg = sess.createTextMessage();
msg.setText("A message from the 'TopicLoad' sample application");

publisher.publish(msg);
conn.close();
}

private static void obtainAdminObjects( Object[] outArray ) {
try {
com.ibm.mq.jms.MQTopicConnectionFactory tcf =
new com.ibm.mq.jms.MQTopicConnectionFactory();
tcf.setQueueManager(qMgrName);
tcf.setBrokerQueueManager(qMgrName);
tcf.setBrokerPubQueue("Sample.Pub"); //existed
tcf.setBrokerSubQueue("Sample.Sub");//existed
tcf.setBrokerControlQueue("Sample.Control");//existed

com.ibm.mq.jms.MQTopic t = new com.ibm.mq.jms.MQTopic();
t.setBaseTopicName(tName);
outArray[0] = tcf;
outArray[1] = t;
} catch( Exception e ) {
System.out.println("Error obtaining admin objects: "+e+"\nQuitting.");
System.exit(-1);
}
}
}

I got an error .
Exception in thread "main" javax.jms.JMSException: MQJMS1111: JMS1.1 no setting essential queue... How can I make this code run ?