MQSeries.net :: View topic - Sending messages to a Distribution List using Java program

jagan · Posted: Thu Sep 26, 2002 8:58 am Post subject:

Hi All,

Iam getting Error message 2136, while iam trying to send a simple message through Distribution List. iam attaching the Java code below. As per the Docus it is saying we have to add MQOD fields. But i could not able to add those fields..

Can any one help me out of this...

Regards
Jagan

My code follows, I created two Queue Manager QM1, and QM2 and Local queues QM1.Local in QM1, and QM2.Local in QM2

and the argument is as below

"java MQPutDistributionList MQ1.LOCAL MQ1 MQ2.LOCAL MQ2"

import com.ibm.mq.*;
import java.util.Hashtable; // Required for properties

public class MQPutDistributionList {

private String qManager = "QM1";

private MQQueueManager qMgr;

MQDistributionListItem[] distrubutionListItems = new MQDistributionListItem[10] ;

MQDistributionList mdl ;

public static void main(String args[]) {

System.out.println("Now In main!!");

new MQPutDistributionList(args);
}
int k =1;
int x=0;
public MQPutDistributionList(String args[]) {

try {
for ( int i=0; i<10;i++) {
distrubutionListItems[i] = new MQDistributionListItem();
}

for ( int i=0; i<2;i++) {
distrubutionListItems[i].queueName = args[x];
System.out.println("QUEUE NAME"+args[x]);
x=x+2;
distrubutionListItems[i].queueManagerName =args[k];
System.out.println("QUEUE MANAGER"+args[k]);
k=k+2;
}

int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING ;

MQMessage hello_world = new MQMessage();
MQPutMessageOptions pmo = new MQPutMessageOptions();
pmo.recordFields=MQC.MQPMRF_MSG_ID |MQC.MQPMRF_CORREL_ID;

hello_world.writeUTF("Second ...Test message Put and Get ... ");

qMgr = new MQQueueManager(qManager);
mdl = qMgr.accessDistributionList(distrubutionListItems,openOptions);
mdl.put(hello_world,pmo);
mdl.close();
qMgr.close();
qMgr.disconnect();
}catch (MQException ex) {
System.out.println("An MQSeries error occurred : Completion code " +
ex.completionCode + " Reason code " + ex.reasonCode);
}
catch (java.io.IOException ex)
{
System.out.println("An error occurred whilst writing to the message buffer: " + ex);
}
}
}