MQSeries.net :: View topic - WSAD5.1 MQSeries5.3 BACK OUT QUEUE(DEAD LETTER QUEUE)

Kareem_khan · Posted: Fri Jul 09, 2004 2:43 pm Post subject:

Hi,
I have configured IBM Websphere for backout Queues in order to put
unprocessed(bad) messages in to Queue strange thing is that even good messages which are processed by Message Driven bean also going to
back out queue I couldnot figure out possible reasons.Here is the test code for MQ Series program as well onMessage method of Message driven bean.It is simpel program trying to put 20 Good and 20 bad messages into the queue and I am expecting 20 bad messages to go into
Back out queue but what I see is that good messages which are prining as Sccuss also going into backout queue.Our intention is to ensure only bad(unprocessed) messages to be their in back out queue so that we figure out way's to process those messages the messages that we are sending in our project are XML documents which need to be processed.
if for some reason could not should go in to back out queue so that we figureout some way to process those bad XML messages.

Here is the example program that I am trying to test so that messages behave accoridingly.

MQSeries client program. that puts 20 bad and 20 good messages

package mdb.test;
import java.util.Hashtable;
import com.ibm.mq.MQC;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
public class TestClient {
public static void main(String[] args) throws Exception
{
putGoodMessages();
putDeadMssage();
}
static void putDeadMssage()throws Exception
{
MQEnvironment.hostname = "100.12.26.56";
MQEnvironment.port =1432;
MQEnvironment.channel = "SP_CHANNEL";
MQQueueManager qMgr = new MQQueueManager("sat.sp.queue.mgr");
MQQueue postingQueue = qMgr.accessQueue("SP_POSTING",MQC.MQOO_OUTPUT);
for(int i=0;i<20;i++)
{
MQMessage message = new MQMessage();
message.format = MQC.MQFMT_STRING;
MQPutMessageOptions options = new MQPutMessageOptions();
options.options = MQC.MQPMO_NO_SYNCPOINT;

message.writeString("Dead Messages Wrong Data");
postingQueue.put(message, options);
}
postingQueue.close();
qMgr.disconnect();
}
static void putGoodMessages()throws Exception
{
MQEnvironment.hostname = "100.12.26.56";
MQEnvironment.port =1432;
MQEnvironment.channel = "SP_CHANNEL";
MQQueueManager qMgr = new MQQueueManager("sat.sp.queue.mgr");
MQQueue postingQueue = qMgr.accessQueue("SP_POSTING",MQC.MQOO_OUTPUT);
for(int j=0;j<20;j++)
{
MQMessage message = new MQMessage();
message.format = MQC.MQFMT_STRING;
MQPutMessageOptions options = new MQPutMessageOptions();
options.options = MQC.MQPMO_NO_SYNCPOINT;
message.writeString("Hello"+j);
postingQueue.put(message, options);
}
postingQueue.close();
qMgr.disconnect();
}

}

onMessageMethod of Message driven bean. print "Sccuss" if message is good else message should go to Back out Queue

public void onMessage(javax.jms.Message msg) {
try
{
TextMessage txtMsg =(TextMessage)msg;
String messageStr= txtMsg.getText();
if(messageStr.length() > 10)
{
throw new Exception("Wrong Data");
}
else
{
System.out.println("Sccuss :"+messageStr);
}
}
catch(JMSException jmsEx){getMessageDrivenContext().setRollbackOnly();}
catch(RuntimeException runEx){getMessageDrivenContext().setRollbackOnly();}
catch(Exception ex){getMessageDrivenContext().setRollbackOnly();}
}