activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <tabish...@gmail.com>
Subject Re: activemq 5.9 Replicated LevelDB FlushCommand cannot cast to Message exception after failover
Date Tue, 12 Nov 2013 19:00:48 GMT
On 11/12/2013 12:06 PM, kal123 wrote:
> How I see following:
> Is leveldb putting msg (Eg. WireFormatInfo, FlushCOmmand?) in store that
> should not go in store?
>
>
> evelDBStore | hawtdispatch-DEFAULT-3
> 2013-11-12 11:40:50,486 | INFO  | Stopping BrokerService[largeamq] due to
> exception, java.io.IOException: org.apache.activemq.command.WireFormatInfo
> cannot be cast to org.apache.activemq.command.Message |
> org.apache.activemq.util.DefaultIOExceptionHandler | LevelDB IOException
> handler.
> java.io.IOException: org.apache.activemq.command.WireFormatInfo cannot be
> cast to org.apache.activemq.command.Message
>          at
> org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:39)
>          at
> org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:543)
>          at
> org.apache.activemq.leveldb.LevelDBClient.might_fail_using_index(LevelDBClient.scala:974)
>          at
> org.apache.activemq.leveldb.LevelDBClient.collectionCursor(LevelDBClient.scala:1270)
>          at
> org.apache.activemq.leveldb.LevelDBClient.queueCursor(LevelDBClient.scala:1194)
>          at
> org.apache.activemq.leveldb.DBManager.cursorMessages(DBManager.scala:708)
>          at
> org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore.recoverNextMessages(LevelDBStore.scala:741)
>          at
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:106)
>          at
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:258)
>          at
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor.hasNext(AbstractStoreCursor.java:145)
>          at
> org.apache.activemq.broker.region.cursors.StoreQueueCursor.hasNext(StoreQueueCursor.java:131)
>          at
> org.apache.activemq.broker.region.Queue.doPageInForDispatch(Queue.java:1876)
>          at
> org.apache.activemq.broker.region.Queue.pageInMessages(Queue.java:2086)
>          at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1581)
>          at
> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)
>          at
> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47)
>          at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
>          at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/activemq-5-9-Replicated-LevelDB-FlushCommand-cannot-cast-to-Message-exception-after-failover-tp4673914p4674231.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
There has been a lot of fixing in the LevelDB area of late, you are 
encouraged to move to a 5.10 SNAPSHOT build.

-- 
Tim Bish
Sr Software Engineer | RedHat Inc.
tim.bish@redhat.com | www.fusesource.com | www.redhat.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/


Mime
View raw message