MQSeries.net :: View topic - javax.jms.JMSException: MQJMS2008: failed to open MQ queue

navjot · Posted: Tue Feb 07, 2006 8:04 am Post subject:

Hi
I am using test server enviornment of websphere 5.1 and embedded MQ.
Cofigured the Topic Connection Factory and Topic. Getting following error-

HI...working fine com.ibm.mq.jms.MQTopicConnectionFactory@93b86773
HI...1
HI...2
HI...111
Exception in thread "P=546534:O=0:CT" javax.jms.JMSException: MQJMS2008: failed to open MQ queue
at com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironment.java:540)
at com.ibm.mq.jms.MQBrokerSubscriptionEngine.sendBrokerMessageInternal(MQBrokerSubscriptionEngine.java:2546)
at com.ibm.mq.jms.MQBrokerSubscriptionEngine.sendBrokerMessageInternal(MQBrokerSubscriptionEngine.java:2747)
at com.ibm.mq.jms.MQBrokerSubscriptionEngine.setDeferredMessage(MQBrokerSubscriptionEngine.java:2851)
at com.ibm.mq.jms.MQBrokerSubscriptionEngine.openSubscription(MQBrokerSubscriptionEngine.java:230)
at com.ibm.mq.jms.MQSession.createTSubscriber(MQSession.java:4580)
at com.ibm.mq.jms.MQTopicSession.createSubscriber(MQTopicSession.java:780)
at Client.main(Client.java:41)

Code is following...

/*
* Created on Jan 30, 2006
*
* To change the template for this generated file go to
* Window>Preferences>Java>Code Generation>Code and Comments
*/

/**
* @author baweja
*
* To change the template for this generated type comment go to
* Window>Preferences>Java>Code Generation>Code and Comments
*/
import javax.jms.*;
import javax.naming.*;

public class Client {

public static void main(String[] args) throws JMSException,NamingException {
System.out.println("HI");

TopicConnectionFactory connectionFactory =
(TopicConnectionFactory)new InitialContext().lookup("theTopicConnectionFactory");
System.out.println("HI...working fine "+ connectionFactory);
TopicConnection connection = connectionFactory.createTopicConnection();
connection.start();
TopicSession topicSession =
connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
// topicSession.start();
System.out.println("HI...1" );
Topic topic =
(Topic)new InitialContext().lookup("theTopic");
TopicPublisher publisher = topicSession.createPublisher(topic);
System.out.println("HI...2" );
Message message = topicSession.createMessage();
message.setJMSType("logMessage");
message.setLongProperty("time", System.currentTimeMillis());
message.setStringProperty("subject", "testing messaging");
message.setStringProperty("message", "testing MDB");
System.out.println("HI...111" );
final TopicSubscriber subscriber = topicSession.createSubscriber(topic);
System.out.println("HI...222" );
System.out.println("HI...3" );
publisher.publish(message);
System.out.println("HI...4" );
System.out.println("Waiting for message...");
final TextMessage message1 = (TextMessage) subscriber.receive();
// To prove that a message have been received
// output it to System.out
System.out.println("Message received:");
System.out.println(message1);
publisher.close();
topicSession.close();
connection.close();
System.out.println("Message sent");

}
}

Getting following error at server startup----
[2/7/06 13:22:06:027 IST] 3092233c JMSEmbeddedPr A MSGS0051I: Queue Manager open for business
[2/7/06 13:22:06:059 IST] 3092233c JMSEmbeddedPr A MSGS0052I: Starting the Broker
[2/7/06 13:22:06:371 IST] 3092233c BrokerManager E MSGS0255E: Broker Manager unable to attach to Queue Manager - unknown Queue
[2/7/06 13:22:06:418 IST] 3092233c JMSService E MSGS0001E: Starting the JMS Server failed with exception: com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2085