MQSeries.net :: View topic - MQPUT1 MQException in Distribution List program

RoyJacob · Posted: Tue Feb 26, 2002 12:27 am Post subject:

I get the following exception when I execute a Java code which implements Distribution List ..Could anyone please suggest a solution

Unable to load message catalog - mqji
MQPUT1 MQException: com.ibm.mqbind.MQInternalException
Exception in thread "main" java.lang.NullPointerException
at com.ibm.mqbind.MQPutMessageOptions.readFrom(MQPutMessageOptions.java:
304)
at com.ibm.mq.MQSESSIONServer.MQPUT(MQSESSIONServer.java:288)
at com.ibm.mq.MQDistributionList.put(MQDistributionList.java:251)
at Dist.main(Dist.java:4

Java code is as below :

import com.ibm.mq.*; // Include the MQSeries classes for Java package

public class Dist
{

public static void main(String args[])
{
try {
MQQueueManager qMgr = new MQQueueManager("QM"); // Create a connection to the queue manager TEST
int openOptions = MQC.MQOO_OUTPUT ;
String userId = "db2admin" ;

// Create an array of MQDistributionListItem objects. Size of the array is determined by the
// number of destination queues.

MQDistributionListItem[] dlitems = new MQDistributionListItem[3];

// Create the individual dlitems of the distribution list

MQDistributionListItem IT1 = new MQDistributionListItem();
MQDistributionListItem IT2 = new MQDistributionListItem();
MQDistributionListItem IT3 = new MQDistributionListItem();

// Set the properties of the Individual dlitems.

IT1.queueManagerName = "QM";
IT1.queueName = "Q1";
IT2.queueManagerName = "QM" ;
IT2.queueName = "Q2" ;
IT3.queueManagerName = "QM" ;
IT3.queueName = "Q3" ;

// Populate the dlitems array with the individaual dlitems

dlitems[0] = IT1;
dlitems[1] = IT2;
dlitems[2] = IT3;

// Create a DistributionList object with the dlitems.
MQDistributionList MyDistribution = new MQDistributionList(qMgr,dlitems,openOptions, userId);
MQMessage MyMesg = new MQMessage();
MyMesg.writeUTF("Test Data ");
MQPutMessageOptions pmo = new MQPutMessageOptions();
MyDistribution.put(MyMesg, pmo); // Send message to the distribution list.
qMgr.commit();
MyDistribution.close();
qMgr.disconnect() ;

}
catch (MQException ex)
{
System.out.println("An MQSeries error occurred : Completion code " +ex.completionCode + " Reason code " +

ex.reasonCode);
}
// Java buffer space error?
catch (java.io.IOException ex)
{
System.out.println("An error occurred whilst writing to the message buffer: " + ex);
}
}

}