Commit f3c2170c authored by afreyssin's avatar afreyssin
Browse files

Bug fixes: Fix the value of NbMsgsReceiveSinceCreation (JORAM-232).

parent 54190ace
......@@ -246,6 +246,7 @@ public class DistributionQueue extends Queue {
for (Iterator ite = msgs.iterator(); ite.hasNext();) {
// Bug fix JORAM-232: now counts received messages.
nbMsgsReceiveSinceCreation++;
Message msg = (Message) ite.next();
try {
distributionModule.processMessage(msg);
......@@ -329,6 +330,9 @@ public class DistributionQueue extends Queue {
List msgs = cm.getMessages();
for (Iterator ite = msgs.iterator(); ite.hasNext();) {
// Bug fix JORAM-232: now counts received messages.
nbMsgsReceiveSinceCreation++;
Message msg = (Message) ite.next();
// a processMessage exception is normal with async mode.
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment