AMQChannel.requeue() will not process all messages if an error occurs during
processing
---------------------------------------------------------------------------------------
Key: QPID-1793
URL: https://issues.apache.org/jira/browse/QPID-1793
Project: Qpid
Issue Type: Bug
Components: Java Broker
Affects Versions: M4, M3
Reporter: Martin Ritchie
Assignee: Martin Ritchie
Fix For: 0.5
Summary:
There is no try/catch in the requeue/dequeueAndDelete loop so if an error
occurs during processing then subsequent messages will not be processed. The
error will also not be propagated to the client as the requeue() method is
called as part of the channel close procedure.
Here it makes more sense to record and log the errors and attempt to process
every message. Once each message has been attempted once then we can throw the
first exception received.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
