[AMQ-277] Multicast is broken and going into infinite loop due to ack problems

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 3.1
• Fix Version/s: 3.1, 3.2
• Component/s: Transport
• Assignee: Alan Cabrera
• Reporter: Stephane Bailliez
• Created: 25/Jun/05 10:09
• Updated: 15/Aug/05 20:24
• Resolved: 15/Aug/05 20:24

Description

Multicast transport is broken in AMQ certainly due to ack problems. Messages are sent over and over, completely flooding the network.

The behavior can be easily shown using the ProducerTool and ConsumerTool (in examples/src)
Using the following command lines:

'java ConsumerTool multicast://224.1.2.3:200 true subject false 100 4321 false'
'java ProducerTool multicast://224.1.2.3:200 true subject false 100 1234 false'
(replace that by your favorite Ant or Maven command)

Here is a sample of what you get in the Consumer console. As you can see it is a mix of messages.

[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 2 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 2 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 2 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 2 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 3 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 2 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 3 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 2 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 4 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 3 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 1 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 0 sent at: Sat Jun 25 11:47:01 CEST 2005 ...
[java] Received: Message: 2 sent at: Sat Jun 25 11:47:02 CEST 2005 ...
[java] Received: Message: 4 sent at: Sat Jun 25 11:47:02 CEST 2005 ...