[AMQ-1650] AmqPersistenceAdapter throws java.io.IOException: Failed to read to journal for: offset

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 5.0.0
• Fix Version/s: 5.1.0
• Component/s: Message Store
• Assignee: Robert Davies
• Reporter: Robert Davies
• Created: 09/Apr/08 13:18
• Updated: 09/Apr/08 13:20
• Resolved: 09/Apr/08 13:20

Description

Using durable consumers with multiple topics - can occasionally see this timing issue:
Caused by: java.io.IOException: Failed to read to journal for: offset = 17883251, file = 2, size = 0, type = 0. Reason: java.io.IOException: Invalid location: offset = 17883251, file = 2, size = 0, type = 0, : java.lang.NegativeArraySizeException
at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:33)
at org.apache.activemq.store.amq.AMQPersistenceAdapter.createReadException(AMQPersistenceAdapter.java:597)
at org.apache.activemq.store.amq.AMQPersistenceAdapter.readCommand(AMQPersistenceAdapter.java:483)
at org.apache.activemq.store.amq.AMQMessageStore.getMessage(AMQMessageStore.java:431)
at org.apache.activemq.store.amq.RecoveryListenerAdapter.recoverMessageReference(RecoveryListenerAdapter.java:54)
at org.apache.activemq.store.kahadaptor.KahaReferenceStore.recoverReference(KahaReferenceStore.java:80)
at org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.recoverNextMessages(KahaTopicReferenceStore.java:285)
at org.apache.activemq.store.amq.AMQTopicMessageStore.recoverNextMessages(AMQTopicMessageStore.java:62)
at org.apache.activemq.broker.region.cursors.TopicStorePrefetch.doFillBatch(TopicStorePrefetch.java:106)
at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:185)
... 27 more
Caused by: java.io.IOException: Invalid location: offset = 17883251, file = 2, size = 0, type = 0, : java.lang.NegativeArraySizeException
at org.apache.activemq.kaha.impl.async.DataFileAccessor.readRecord(DataFileAccessor.java:95)
at org.apache.activemq.kaha.impl.async.AsyncDataManager.read(AsyncDataManager.java:585)
at org.apache.activemq.store.amq.AMQPersistenceAdapter.readCommand(AMQPersistenceAdapter.java:480)
... 34 more