MQSeries.net :: View topic - Channel definition tables with MQ 6.0 for java application

hilltops · Posted: Wed Sep 13, 2006 7:47 am Post subject:

I am having problems connecting to a queue manager from an MQ client application written in Java. The MQI channel is defined using a channel definition table. I am not using any environment variables but point to the location of the channel definition table using the url object as in;

chldefurl = new URL("file://home/mqm/AMQCLCHL.TAB");

I then build the queue manager object using thus object;

MQQueueManager qMgr = new MQQueueManager("TEST", chldefurl);

The channels are defined on the queue manager TEST as;

DEFINE CHANNEL(SVRCONN.TEST) CHLTYPE(SVRCONN) TRPTYPE(TCP) +
DESCR('Server connection on queue manager TEST') +
replace

DEFINE CHANNEL(SVRCONN.TEST) CHLTYPE(CLNTCONN) TRPTYPE(TCP) +
DESCR('Client connection to queue manager TEST') +
CONNAME('abcdefgh.SYSTEMS.UK.XXXX(15003)') +
QMNAME(TEST) +
REPLACE

And I have copied the channel def table for its default location to home/mqm/AMQCLCHL.TAB.

When I run the application I get 2278 (MQRC_CLIENT_CONN_ERROR). Anyone had this problem.

Thanx

The Sample code follows;

###############################################

import com.ibm.mq.*;
import java.net.*;

public class SSLSample2 {

// define the parms
private static String conname ;
private static String port ;
private static String channel ;
private static String qmgr ;
private static String sslciph ;
private static String sslkeyr ;
private static String sslpass ;

private MQQueue reqQueue;
private String reqQName = "TEST.QUEUE";

public static void main(String args[]) {
new SSLSample2().runSample();
}

public void runSample() {
try {

java.net.URL chldefurl = null;

try{
chldefurl = new URL("file://home/mqm/AMQCLCHL.TAB");
}
catch(Exception e){
System.out.println("Malformed URL...Quiting");
System.exit(1);
}

MQQueueManager qMgr = new MQQueueManager("TEST", chldefurl);
int openOptions = MQC.MQOO_OUTPUT ;
reqQueue = qMgr.accessQueue(reqQName, openOptions);
MQMessage myMessage = new MQMessage();
myMessage.writeUTF("Testing");
MQPutMessageOptions pmo = new MQPutMessageOptions();
reqQueue.put(myMessage,pmo);

System.out.println("Connection successful!");

try{
System.out.println("Hold connection open for 60s. Go check that the SVRCONN is running!");
Thread.sleep(60000);
}
catch(Exception e){
}

System.out.println("Disconnecting from the Queue Manager");
qMgr.disconnect();
System.out.println("Done!");
}
catch (Exception ex) {
System.out.println("A WebSphere MQ Error occured : ..................");
ex.printStackTrace();

}
}
}
###############################################