RecoveryListenerAdapter - Message id ID... could not be recovered from the data store: WAS: [Duplicate message delivered to consumers on queue with kaha persistence]

> Hi Rob,
>
> Looks like the AMQ store works correctly - thanks for the advice.
>
> Cheers,
> David
>
> Rob Davies wrote:
>> Do you get the same using AMQ store (the default in 5.0) - its the
>> prefered store over kaha in ActiveMQ 5.0
>>
>>
>>
>> cheers,
>>
>> Rob
>>
>> http://rajdavies.blogspot.com/
>>
>>
>>
>> On Oct 3, 2007, at 8:50 AM, David Sitsky wrote:
>>
>>> I have discovered an issue with the latest activemq 5.0 (revision
>>> 581510) which seems to have been present for some time, at least for
>>> the last month.
>>>
>>> I have an application using transactions, and kaha persistence, and
>>> two consumers feeding off a queue.
>>>
>>> I sometimes see the same message being sent to two consumers.  All
>>> transactions were committed (no rollbacks), and as you can see by the
>>> debug dump, the message has the same message-ID, but was delivered to
>>> two separate consumers, running on separate threads, using sync
>>> receives with a prefetch of 0, with separate sessions of course.
>>>
>>> Is this a known problem?  It doesn't always happen - seems to be a
>>> race condition.  If I turn off persistence, I don't seem to see it.
>>>
>>> Here is the message being delivered to consumer 1:
>>>
>>> 2007-10-03 17:21:37,310 [Worker 060bacd87f4a40a4867113e2e3e553dd]
>>> 85475 DEBUG org.apache.activemq.ActiveMQMessageConsumer -
>>> ID:tamarama-62436-1191396093006-2:2:3:2 received message:
>>> MessageDispatch {commandId = 0, responseRequired = false, consumerId
>>> = ID:tamarama-62436-1191396093006-2:2:3:2, destination =
>>> queue://worker-items, message = ActiveMQObjectMessage {commandId =
>>> 50, responseRequired = false, messageId =
>>> ID:tamarama-62436-1191396093006-2:2:1:3:1, originalDestination =
>>> null, originalTransactionId = null, producerId =
>>> ID:tamarama-62436-1191396093006-2:2:1:3, destination =
>>> queue://worker-items, transactionId =
>>> TX:ID:tamarama-62436-1191396093006-2:2:5, expiration = 0, timestamp =
>>> 1191396097286, arrival = 0, brokerInTime = 1191396097290,
>>> brokerOutTime = 1191396097303, correlationId = null, replyTo = null,
>>> persistent = true, type = null, priority = 4, groupID = null,
>>> groupSequence = 0, targetConsumerId = null, compressed = false,
>>> userID = null, content =
>>> org.apache.activemq.util.ByteSequence@fa8cbc, marshalledProperties =
>>> null, dataStructure = null, redeliveryCounter = 0, size = 0,
>>> properties = null, readOnlyProperties = true, readOnlyBody = true,
>>> droppable = false}, redeliveryCounter = 0}
>>>
>>> Here is the same message (check the message ID) being delivered to
>>> consumer 2:
>>>
>>> 2007-10-03 17:21:37,422 [Worker 2c3169d1726b4781a423a239f65c7bd1]
>>> 85587 DEBUG org.apache.activemq.ActiveMQMessageConsumer -
>>> ID:tamarama-62436-1191396093006-2:2:1:2 received message:
>>> MessageDispatch {commandId = 0, responseRequired = false, consumerId
>>> = ID:tamarama-62436-1191396093006-2:2:1:2, destination =
>>> queue://worker-items, message = ActiveMQObjectMessage {commandId =
>>> 50, responseRequired = false, messageId =
>>> ID:tamarama-62436-1191396093006-2:2:1:3:1, originalDestination =
>>> null, originalTransactionId = null, producerId =
>>> ID:tamarama-62436-1191396093006-2:2:1:3, destination =
>>> queue://worker-items, transactionId =
>>> TX:ID:tamarama-62436-1191396093006-2:2:5, expiration = 0, timestamp =
>>> 1191396097286, arrival = 0, brokerInTime = 1191396097290,
>>> brokerOutTime = 1191396097417, correlationId = null, replyTo = null,
>>> persistent = true, type = null, priority = 4, groupID = null,
>>> groupSequence = 0, targetConsumerId = null, compressed = false,
>>> userID = null, content =
>>> org.apache.activemq.util.ByteSequence@1a881cc, marshalledProperties =
>>> null, dataStructure = null, redeliveryCounter = 0, size = 0,
>>> properties = null, readOnlyProperties = true, readOnlyBody = true,
>>> droppable = false}, redeliveryCounter = 0}
>>>
>>> I'll need to do more investigations tomorrow, but if anybody has any
>>> ideas, I'd appreciate some insights.
>>>
>>> --
>>> Cheers,
>>> David
>>>
>>> Nuix Pty Ltd
>>> Suite 79, 89 Jones St, Ultimo NSW 2007, Australia    Ph: +61 2 9280 0699
>>> Web: http://www.nuix.com                            Fax: +61 2 9212 6902
>
>