MQSeries.net :: View topic

maheswarank · Posted: Wed Jan 23, 2002 4:19 am Post subject:

hi there

i am also having the same problem in message segmenting, i am not able to put a segmented message, even if i try putting it the groupid which i set before putting the message, is null when i get the message.
i have given the program in which i try to put a single message of a group,
but when i use this line in my program
myMessage.messageFlags = MQC.MQGS_MSG_IN_GROUP;
i get a run time error # 2249(MQRC_MSG_FLAGS_ERROR).

i would be grateful if anyone can guide me, in this problem

import com.ibm.mq.*;
public class messageput
{
public static void main(String a[]) throws Exception
{
MQEnvironment.hostname = "c-520";
MQEnvironment.channel = "SYSTEM.DEF.SVRCONN";
MQEnvironment.port = 1414;
MQQueueManager qmgr = null;

try
{
qmgr = new MQQueueManager("god");
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT ;
MQQueue queue = qmgr.accessQueue("Devil", openOptions, null, null, null);

String grp = "Group 1: 001";
MQMessage myMessage = new MQMessage();

myMessage.groupId = grp.getBytes();
//myMessage.messageFlags = MQC.MQGS_MSG_IN_GROUP;
System.out.println("Group ID : " + new String(myMessage.groupId));

String name = "1.1 mess";

myMessage.writeString(name);

MQPutMessageOptions pmo = new MQPutMessageOptions();
pmo.options = MQC.MQPMO_LOGICAL_ORDER;

queue.put(myMessage,pmo);

myMessage = new MQMessage();
queue.put(myMessage,pmo);
queue.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);
}
}
}