Multiple creating and closing consumers causes messages duplicated delivered
----------------------------------------------------------------------------
Key: AMQ-1767
URL: https://issues.apache.org/activemq/browse/AMQ-1767
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.1.0
Environment: Windows XP, Java 1.5
Reporter: Kevin
Attachments: JUnit.zip
Hi *,
I'm running AcitveMQ 5.1 in a VM. The broker is set as persistent with
amq-store, the xml-configuration-file is attached (in the zip-file).
One MessageProducer sends 10.000 messages to a queue. The producers runs in its
own thread with its own session.
The queue is set as transacted.
Two MessageConsumers register on the queue mentioned above, each in its own
thread with its own session.
The Producer and the Consumers share one connection-object.
Every second one Consumer is called to be canceld (by session.close - a call to
consumer.close does not help), its thread is stopped and a new Consumer is
created in a new thread with its own session.
What happens?
1 to 10 messages are duplicated delivered from some consumers. So the
'EnqueueCount' is greater than the 'DequeueCount'. E.G. 10.002 messages are
recieved, but just 10.000 messages are sent.
I've tried to synchronized by one common-object the creating, closing or
commiting in the Consumer with no success.
Attached is a junit-test, which demonstrates the situation. Before have a look
at the Config-Class and change the ip-address, where your broker runs.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
