Incorrect number of messages received using multiple consumers
--------------------------------------------------------------
Key: QPID-390
URL: https://issues.apache.org/jira/browse/QPID-390
Project: Qpid
Issue Type: Bug
Components: Java Broker
Affects Versions: M1
Reporter: Marnie McCormack
Fix For: M2
Run two consumers against an initial queue depth of 100. After the test,
Received Message Count is 4437, rather than 100 e.g.
/** multiple consumers */
public void testTwoCompetingConsumers() throws Exception
{
Consumer c1 = new Consumer();
Consumer c2 = new Consumer();
Thread t1 = new Thread(c1);
Thread t2 = new Thread(c2);
t1.start();
t2.start();
t1.join();
t2.join();
log("consumer 1 count is " + c1.getCount());
log("consumer 2 count is " + c2.getCount());
Integer totalConsumed = c1.getCount()+c2.getCount();
assertEquals("number of consumed messages does not match initial data",
numTestMessages, totalConsumed);
}
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
