MQSeries.net :: View topic

pnsrikanth · Posted: Wed Jun 19, 2002 4:51 am Post subject: MQSI pubsub broker error

Hi

I am using the following setup for MQSI V2 PUBSUB broker via JNDI
The client/publisher/subscriber program is written in JMS
MQSI Broker is setup in QM(HKGBRK03D) and a simple message flow is also deployed in the broker

InitCtx> display TCF(pstcf)

BROKERCCSUBQ(MANI_OUT_Q)
BROKERPUBQ(ps_in_q)
QMANAGER(HKGBRK03D)
SUBSTORE(MIGRATE)
BROKERVER(V2)
USECONNPOOLING(YES)
POLLINGINT(5000)
CLONESUPP(DISABLED)
BROKERQMGR(HKGBRK03D)
BROKERSUBQ(ps_out_q)
STATREFRESHINT(60000)
TRANSPORT(CLIENT)
HOSTNAME(172.27.142.41)
CHANNEL(SYSTEM.DEF.SVRCONN)
SYNCPOINTALLGETS(NO)
PUBACKINT(25)
CCSID(819)
CLEANUPINT(3600000)
PORT(6666)
MSGSELECTION(CLIENT)
VERSION(2)
MSGBATCHSZ(10)
BROKERCONQ(SYSTEM.BROKER.CONTROL.QUEUE)
CLEANUP(SAFE)

InitCtx> display T(pst)

BROKERDURSUBQ(ps2_out_q)
TOPIC(exel/efe/tr/ack)
BROKERVER(V2)
PERSISTENCE(APP)
CCSID(1208)
TARGCLIENT(JMS)
ENCODING(NATIVE)
BROKERCCDURSUBQ(MANI2_OUT_Q)
PRIORITY(APP)
EXPIRY(APP)
VERSION(1)

The following error appears
Exception in thread "main" javax.jms.JMSException: MQJMS5062: Please ensure the
broker is installed on this queue manager
at com.ibm.mq.jms.services.ConfigEnvironment.newException(ConfigEnvironm
ent.java:546)
at com.ibm.mq.jms.MQTopicConnection.createUniqueID(MQTopicConnection.jav
a:789)
at com.ibm.mq.jms.MQTopicConnection.<init>(MQTopicConnection.java:246)
at com.ibm.mq.jms.MQTopicConnection.<init>(MQTopicConnection.java:112)
at com.ibm.mq.jms.MQTopicConnectionFactory.createMQTopicConnection(MQTop
icConnectionFactory.java:314)
at com.ibm.mq.jms.MQTopicConnectionFactory.createTopicConnection(MQTopic
ConnectionFactory.java:215)
at psmqsi.main(psmqsi.java, Compiled Code)

I do get the same probelm when i try it with out jndi alsothe code with out jndi

com.ibm.mq.jms.MQTopicConnectionFactory ibmtcf = new com.ibm.mq.jms.MQTopicConnectionFactory();
ibmtcf.setTransportType(com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
ibmtcf.setChannel("SYSTEM.DEF.SVRCONN");
ibmtcf.setHostName("172.27.142.41");
ibmtcf.setPort(6666);
ibmtcf.setQueueManager("HKGBRK03D");
ibmtcf.setBrokerQueueManager("HKGBRK03D");
ibmtcf.setBrokerControlQueue("SYSTEM.BROKER.CONTROL.QUEUE");
ibmtcf.setBrokerPubQueue("ps_in_q");
ibmtcf.setBrokerVersion(0);
TopicConnectionFactory tcf =
(TopicConnectionFactory)ibmtcf;

//tcf.setBrokerQueueManager("HKGBRK03D");
System.out.println("Create a topic connection" + "\n");

TopicConnection tConn = tcf.createTopicConnection();

Does any one solved such issues?