Hi again, some more tests showed, that you need just one consumer to see the problem:
10.000 messages are in a queue (persistent by the amq-store; prefetch size is 1). Now create a consumer in his own thread, recieve messages and after awhile - let's say 1 second - close the consumer and create a new consumer within a new thread. At the end, when all messages are delivered, you see, that more than 10.000 messages were delivered. These messages were duplicated recieved by consumers. I'm pretty sure, that my code is correct. But maybe this is a configuration-setting. Or is it a bug? Or perhaps ActiveMQ can't do such things and we need to leave ActiveMQ and go ahead to another implementation? Cheers, Kevin -- View this message in context: http://www.nabble.com/Closing-a-consumer-create-more-messages-than-sent-tp17602690s2354p17640047.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
