MQSeries.net :: View topic

naylak · Posted: Fri Feb 27, 2004 8:27 am Post subject:

Hi All!

I have written the following piece of code . I want to put a big message in a queue. So I am going for segmentation. As far as I understood segmentation I have written the following piece of code and tested it. I am getting reason code 2253 which means my offset is 0. I have changed the value but I am still getting it as can be seen in the code.

_____________________________________________________________

import com.ibm.mq.*;
import java.io.*;
public class MQPut
{
public static void main(String args[]) throws Exception
{
System.out.println("MQPutDemo started...");

MQQueueManager qMgr = new MQQueueManager("CBINBRQM");
String queueName = "CBINGWQ";
MQMessage myMessage = new MQMessage();
myMessage.messageFlags = MQC.MQMF_SEGMENT;
myMessage.offset = 1024;

MQPutMessageOptions pmo1 = new MQPutMessageOptions();
pmo1.options = pmo1.options|MQC.MQPMO_LOGICAL_ORDER|MQC.MQPMO_SET_IDENTITY_CONTEXT | MQC.MQPMO_SYNCPOINT ;
int openOptions = MQC.MQOO_OUTPUT | MQC.MQPMO_SET_IDENTITY_CONTEXT ;
MQQueue myQueue = qMgr.accessQueue(queueName ,openOptions,null,null,null);

File f = new File("demo.zip");
FileInputStream fis = new FileInputStream("Installation Manual-Branch.doc");
long length = f.length();
byte[] bts = new byte[(int)length];
fis.read(bts);
fis.close();

myMessage.write(bts);

myQueue.put(myMessage, pmo1);
myQueue.close();
qMgr.disconnect();
}
}

_____________________________________________________________