Details
Description
I have written a test case which will demonstrate the following scenarios:
1. Simple producer driving a queue, simple consumer pulling from the queue.
2. Simple producer driving a queue, simple consumer pulling from the queue and producing an echo of the original message into the same queue.
Expected: message delivery should not be interrupted.
Actual: in scenario 2, eventually (about 500k messages in my environment), the delivery is halted to the consumer.
Test Output:
waiting for consumer to pause ... consumer: 0, producer: 0
waiting for consumer to pause ... consumer: 3738, producer: 29796
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841
waiting for consumer to pause ... consumer: 9224, producer: 67841