Message persistence migration

[Eduardo Corral <ec...@tid.es>]

Hi everyone

We are performing some tests with different broker versions (4.1.1, 
4.2-SNAPSHOT, 5.0-SNAPSHOT). In one particular test, we had 1 message 
remaining on a queue, persisted over DB with JDBC. The broker was the 
4.2. Later, we changed the broker to the 5.0, and started it. When 
trying to consume that message, we got an exception (full stack below):

java.lang.NegativeArraySizeException
        at 
org.apache.activemq.openwire.v3.MessageMarshaller.looseUnmarshal(MessageMarshaller.java:247)

This raises a question: what happens with old persisted messages when 
moving to a newer broker version? Is there a need for a special 
migrating procedure?

Thank you and best regards
Eduardo Corral

Full exception:

java.lang.NegativeArraySizeException
        at 
org.apache.activemq.openwire.v3.MessageMarshaller.looseUnmarshal(MessageMarshaller.java:247)
        at 
org.apache.activemq.openwire.v3.ActiveMQMessageMarshaller.looseUnmarshal(ActiveMQMessageMarshaller.java:101)
        at 
org.apache.activemq.openwire.v3.ActiveMQObjectMessageMarshaller.looseUnmarshal(ActiveMQObjectMessageMarshaller.java:101)
        at 
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:351)
        at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:206)
        at 
org.apache.activemq.store.jdbc.JDBCMessageStore$2.recoverMessage(JDBCMessageStore.java:239)
        at 
org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRecoverNextMessages(DefaultJDBCAdapter.java:677)
        at 
org.apache.activemq.store.jdbc.JDBCMessageStore.recoverNextMessages(JDBCMessageStore.java:234)
        at 
org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:80)
        at 
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.fillBatch(QueueStorePrefetch.java:159)
        at 
org.apache.activemq.broker.region.cursors.QueueStorePrefetch.hasNext(QueueStorePrefetch.java:110)
        at 
org.apache.activemq.broker.region.cursors.StoreQueueCursor.hasNext(StoreQueueCursor.java:122)
        at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1007)
        at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:992)
        at 
org.apache.activemq.broker.region.Queue.addSubscription(Queue.java:215)
        at 
org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:241)
        at 
org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:341)
        at 
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:87)
        at 
org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:79)
        at 
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:87)
        at 
org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:97)
        at 
org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:566)
        at 
org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:313)
        at 
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:282)
        at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)
        at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
        at 
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133)
        at 
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:126)
        at 
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
        at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
        at java.lang.Thread.run(Thread.java:595)