How to reattempt individual message
-----------------------------------
Key: AMQ-3423
URL: https://issues.apache.org/jira/browse/AMQ-3423
Project: ActiveMQ
Issue Type: Task
Environment: Linux
Reporter: srikanth reddy
Hi,
I am implementing ActiveMQ Middleware using point to point .
I am facing this issue from last few days
There are multiple message posted to my activemq and one i start activemq my
session starts reading messages.I am using individual message acknowledgement.
i.e qConnection.createQueueSession(false,
ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE);
Once i receive message in my message listener i am sending message to child
thread and processing message there and processing is completed i am sending
acknowledgement.
But problem here is if any exception comes in middle of my message i want to
reattempt for that specific message.
I have tryed session.recover here but its recovering all messages on that
session which is wrong
Please look into my message consumer and listener
Consumer class outline
public QueueSession session = null;
public QueueConnection qConnection = null;
ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(url);
qConnection = connectionFactory.createQueueConnection();
session = qConnection.createQueueSession(false,
ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE);
QueueReceiver _receiver =
session.createReceiver(getTransactionQueue(session));
_receiver.setMessageListener(getMessageListener());
public void onMessage(Message message) {
//starting chaild thread etc
if(doprocess()){
session.acknowledge();
} else {
//want to roll back particlur message
}
}
Please help me to resolve this issue
Thanks & Regards
Srikanth Reddy
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
