You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Gary Tully (JIRA)" <ji...@apache.org> on 2013/03/13 15:08:31 UTC

[jira] [Assigned] (AMQ-4369) Default IOException handler needs to be set before Persistence adapter and network connectors are started

     [ https://issues.apache.org/jira/browse/AMQ-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gary Tully reassigned AMQ-4369:
-------------------------------

    Assignee: Gary Tully
    
> Default IOException handler needs to be set before Persistence adapter and network connectors are started
> ---------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-4369
>                 URL: https://issues.apache.org/jira/browse/AMQ-4369
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.8.0
>            Reporter: Gary Tully
>            Assignee: Gary Tully
>             Fix For: 5.9.0
>
>
> It is possible to get an IOException before the current default handler is installed, so it is bypassed. It needs to be set earlier.
> {code}2013-03-11 09:51:24,409 | INFO  | No IOExceptionHandler registered, ignoring IO exception, java.io.IOException: Input/output error | org.apache.activemq.broker.BrokerService | ActiveMQ Transport: ssl:///xxx:yyy
> java.io.IOException: Input/output error
> 	at java.io.RandomAccessFile.readBytes(Native Method)
> 	at java.io.RandomAccessFile.read(RandomAccessFile.java:355)
> 	at java.io.RandomAccessFile.readFully(RandomAccessFile.java:414)
> 	at java.io.RandomAccessFile.readFully(RandomAccessFile.java:394)
> 	at org.apache.kahadb.page.PageFile.readPage(PageFile.java:833)
> 	at org.apache.kahadb.page.Transaction$2.readPage(Transaction.java:447)
> 	at org.apache.kahadb.page.Transaction$2.<init>(Transaction.java:438)
> 	at org.apache.kahadb.page.Transaction.openInputStream(Transaction.java:435)
> 	at org.apache.kahadb.page.Transaction.load(Transaction.java:411)
> 	at org.apache.kahadb.page.Transaction.load(Transaction.java:368)
> 	at org.apache.kahadb.index.BTreeIndex.loadNode(BTreeIndex.java:262)
> 	at org.apache.kahadb.index.BTreeIndex.getRoot(BTreeIndex.java:174)
> 	at org.apache.kahadb.index.BTreeIndex.remove(BTreeIndex.java:194)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.updateIndex(MessageDatabase.java:1212)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$15.execute(MessageDatabase.java:1028)
> 	at org.apache.kahadb.page.Transaction.execute(Transaction.java:771)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1026)
> 	at org.apache.activemq.store.kahadb.MessageDatabase$13.visit(MessageDatabase.java:961)
> 	at org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand.visit(KahaRemoveMessageCommand.java:220)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:953)
> 	at org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:865)
> 	at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.removeMessage(KahaDBStore.java:439)
> 	at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.removeAsyncMessage(KahaDBStore.java:411)
> 	at org.apache.activemq.store.kahadb.KahaDBTransactionStore.removeAsyncMessage(KahaDBTransactionStore.java:468)
> 	at org.apache.activemq.store.kahadb.KahaDBTransactionStore$1.removeAsyncMessage(KahaDBTransactionStore.java:171)
> 	at org.apache.activemq.broker.region.Queue.acknowledge(Queue.java:830)
> 	at org.apache.activemq.broker.region.Queue.removeMessage(Queue.java:1584)
> 	at org.apache.activemq.broker.region.QueueSubscription.acknowledge(QueueSubscription.java:59)
> 	at org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:294)
> 	at org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:426)
> 	at org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:537)
> 	at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:77)
> 	at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:77)
> 	at org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:287)
> 	at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:77)
> 	at org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:77)
> 	at org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:87)
> 	at org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:461)
> 	at org.apache.activemq.command.MessageAck.visit(MessageAck.java:236)
> 	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
> 	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150)
> 	at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
> 	at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
> 	at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:268)
> 	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
> 	at org.apache.activemq.transport.tcp.SslTransport.doConsume(SslTransport.java:91)
> 	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:215)
> 	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:197)
> 	at java.lang.Thread.run(Thread.java:679){code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira