Has anyone seen this before?
After this exception the broker shuts down and is restarted by the wrapper but then we
get "kahadb\lock could not be locked as lock is already held for this jvm.".
So there are actually two problems. Why does the broker shut down at all and
why is the restart not working?
I would be happy about any feedback.
Christian
------
2017-01-30 03:56:26,910 | ERROR | KahaDB failed to store to Journal |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Transport:
tcp:///10.218.8.223:49837@61616
java.io.IOException: The parameter is incorrect
at java.io.RandomAccessFile.readBytes(Native Method)[:1.7.0_13]
at java.io.RandomAccessFile.read(Unknown Source)[:1.7.0_13]
at java.io.RandomAccessFile.readFully(Unknown Source)[:1.7.0_13]
at java.io.RandomAccessFile.readFully(Unknown Source)[:1.7.0_13]
at
org.apache.activemq.util.RecoverableRandomAccessFile.readFully(RecoverableRandomAccessFile.java:75)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.page.PageFile.readPage(PageFile.java:878)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.readPage(Transaction.java:456)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.<init>(Transaction.java:447)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.page.Transaction.openInputStream(Transaction.java:444)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:420)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:377)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.loadNode(BTreeIndex.java:262)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.index.BTreeNode.getChild(BTreeNode.java:225)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.index.BTreeNode.getLeafNode(BTreeNode.java:676)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.index.BTreeNode.put(BTreeNode.java:369)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.put(BTreeIndex.java:189)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.MessageDatabase.updateIndex(MessageDatabase.java:1304)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.MessageDatabase$11.execute(MessageDatabase.java:1140)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transaction.java:779)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1137)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.MessageDatabase$10.visit(MessageDatabase.java:1074)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.data.KahaAddMessageCommand.visit(KahaAddMessageCommand.java:241)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1071)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:978)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:958)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.addMessage(KahaDBStore.java:424)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.KahaDBTransactionStore.addMessage(KahaDBTransactionStore.java:388)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.store.kahadb.KahaDBTransactionStore$1.addMessage(KahaDBTransactionStore.java:160)[activemq-kahadb-store-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:913)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.region.Queue.send(Queue.java:733)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:424)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:445)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:297)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:147)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:307)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:152)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:496)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:756)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:148)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)[activemq-client-5.10.0.jar:5.10.0]
at java.lang.Thread.run(Unknown Source)[:1.7.0_13]
--
Christian Schneider
http://www.liquid-reality.de
Open Source Architect
http://www.talend.com
