Text Messages not getting acknowleged when consumed from dead message queue
Hi,
I have a program that acts as a consumer for mq.sys.dmq and routes those messages to other queue. When type of a message in a queue is TextMessage, it never gets acknowledged.
In the broker log, I see following error :
[28/Sep/2006:12:56:43 EDT] ERROR [B3007]: Message 45-10.44.57.68(87:ab:da:aa:d6:c7)-39799-1159462292204 could not be fou
nd in the store
[28/Sep/2006:12:56:43 EDT] Internal error, unable to update state of the message :
com.sun.messaging.jmq.jmsserver.util.BrokerException: Message 45-10.44.57.68(87:ab:da:aa:d6:c7)-39799-1159462292204 coul
d not be found in the store
at com.sun.messaging.jmq.jmsserver.persist.file.DstMsgStore.getMessageInfo(DstMsgS tore.java:416)
at com.sun.messaging.jmq.jmsserver.persist.file.DstMsgStore.updateInterestState(Ds tMsgStore.java:697)
at com.sun.messaging.jmq.jmsserver.persist.file.MsgStore.updateInterestState(MsgSt ore.java:612)
at com.sun.messaging.jmq.jmsserver.persist.file.FileStore.updateInterestState(File Store.java:787)
at com.sun.messaging.jmq.jmsserver.core.PacketReference.delivered(PacketReference. java:1317)
at com.sun.messaging.jmq.jmsserver.core.Session.fillNextPacket(Session.java:556)
at com.sun.messaging.jmq.jmsserver.service.imq.IMQConnection.fillNextPacket(IMQCon nection.java:2510)
at com.sun.messaging.jmq.jmsserver.service.imq.IMQConnection.writeData(IMQConnecti on.java:2032)
at com.sun.messaging.jmq.jmsserver.service.imq.IMQConnection.process(IMQConnection .java:803)
at com.sun.messaging.jmq.jmsserver.service.imq.OperationRunnable.process(Operation Runnable.java:141)
at com.sun.messaging.jmq.jmsserver.util.pool.BasicRunnable.run(BasicRunnable.java: 459)
at java.lang.Thread.run(Thread.java:595)
[28/Sep/2006:12:56:43 EDT] ERROR [B3007]: Message 45-10.44.57.68(87:ab:da:aa:d6:c7)-39799-1159462292204 could not be fou
nd in the store
[28/Sep/2006:12:56:43 EDT] ERROR Internal Error processing ack on 45-10.44.57.68(87:ab:da:aa:d6:c7)-39799-1159462292204
for [consumer:8314223209520637440, type=AUTO_ACKNOWLEDGE]:
com.sun.messaging.jmq.jmsserver.util.BrokerException: Message 45-10.44.57.68(87:ab:da:aa:d6:c7)-39799-1159462292204 coul
d not be found in the store
at com.sun.messaging.jmq.jmsserver.persist.file.DstMsgStore.getMessageInfo(DstMsgS tore.java:416)
at com.sun.messaging.jmq.jmsserver.persist.file.DstMsgStore.updateInterestState(Ds tMsgStore.java:697)
at com.sun.messaging.jmq.jmsserver.persist.file.MsgStore.updateInterestState(MsgSt ore.java:612)
at com.sun.messaging.jmq.jmsserver.persist.file.FileStore.updateInterestState(File Store.java:787)
at com.sun.messaging.jmq.jmsserver.core.PacketReference.acknowledged(PacketReferen ce.java:1466)
at com.sun.messaging.jmq.jmsserver.core.Session$ackEntry.acknowledged(Session.java :430)
at com.sun.messaging.jmq.jmsserver.core.Session.ackMessage(Session.java:973)
at com.sun.messaging.jmq.jmsserver.data.handlers.AckHandler.handleAcks(AckHandler. java:271)
at com.sun.messaging.jmq.jmsserver.data.handlers.AckHandler.handle(AckHandler.java :164)
at com.sun.messaging.jmq.jmsserver.data.PacketRouter.handleMessage(PacketRouter.ja va:146)
at com.sun.messaging.jmq.jmsserver.service.imq.IMQConnection.readData(IMQConnectio n.java:1847)
I am using a 3.6 broker which comes preinstalled with SJSAS 8.1. Note that I have tried using a standalone message listener , a MDB as well as a syncronous consumer of the messages from dead message queue. Every type of client resulting into unacknowleded message. I don't see this behavior with ObjectMessage message.
Can you please help.
Manisha.
