Re: Too many "-"s problem

Rob Davies Sun, 24 Jun 2007 22:23:34 -0700

The ones with 'index' in the name.
Tom is this still easily reproducible from the latest code ?


thanks,

Rob
On Jun 24, 2007, at 8:32 AM, Tom Samplonius wrote:

  Which of the Kaha files are the index files?


----- "James Strachan" <[EMAIL PROTECTED]> wrote:
BTW if things like this happen; the work around is to stop the broker
& zap the index files, then restart. Though we should make the broker
automatically re-create the index files if things get corrupted :)


On 6/6/07, Hiram Chirino <[EMAIL PROTECTED]> wrote:
Hum.. looks like there is some corruption going on.  Will have to
dig
into this and get back with you.  The new message store in ActiveMQ
4.2 is brand new and as you can tell we are still working out the
kinks.  If you want, you can switch to using the old mechanism used
in
4.1.

On 6/4/07, Tom Samplonius <[EMAIL PROTECTED]> wrote:
  There is a problem when using the default persistence settings,
and
ActiveMQ is shutdown uncleanly with messages in a queue.  After a
restart (and log recovery), and attempt to read a message out of
the
queue, generates the following error (and ActiveMQ hangs).

   It appears that there are too many "-" in a concatenation
somewhere,
as the logfiles are "data-1", "data-2", etc, not "data--1", which
is
probably is what is generating the exception.

  This is with 4.2-SNAPSHOT-20070602.
ERROR AsyncDataManager               - Looking for key 1 but not
found
in fileMap: {3=data-3 number = 3 , length = 9051046 refCount =
3}
ERROR QueueStorePrefetch             - Failed to fill batch
java.io.IOException: Failed to read to journal for: offset =
20785811,
file = 1, size = -1, type = 0. Reason: java.io.IOException:
Could not
locate data file data--1
        at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:31)
        at
org.apache.activemq.store.amq.AMQPersistenceAdapter.createReadException(AMQPersistenceAdapter.java:529)
        at
org.apache.activemq.store.amq.AMQPersistenceAdapter.readCommand(AMQPersistenceAdapter.java:409)
        at
org.apache.activemq.store.amq.AMQMessageStore.getMessage(AMQMessageStore.java:382)
        at
org.apache.activemq.store.amq.RecoveryListenerAdapter.recoverMessageReference(RecoveryListenerAdapter.java:52)
        at
org.apache.activemq.store.kahadaptor.KahaReferenceStore.recover(KahaReferenceStore.java:63)
        at
org.apache.activemq.store.kahadaptor.KahaReferenceStore.recoverNextMessages(KahaReferenceStore.java:89)
        at
org.apache.activemq.store.amq.AMQMessageStore.recoverNextMessages(AMQMessageStore.java:477)
        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.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:81)
        at
org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:119)
        at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompSubscribe(ProtocolConverter.java:351)
        at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:149)
        at
org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:71)
        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)
Caused by: java.io.IOException: Could not locate data file
data--1
        at
org.apache.activemq.kaha.impl.async.AsyncDataManager.getDataFile(AsyncDataManager.java:259)
        at
org.apache.activemq.kaha.impl.async.AsyncDataManager.read(AsyncDataManager.java:477)
        at
org.apache.activemq.store.amq.AMQPersistenceAdapter.readCommand(AMQPersistenceAdapter.java:406)
        ... 30 more
--
Regards,
Hiram

Blog: http://hiramchirino.com
--
James
-------
http://macstrac.blogspot.com/

Re: Too many "-"s problem

Reply via email to