[
https://issues.apache.org/jira/browse/AMQ-8356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arnout Engelen updated AMQ-8356:
--------------------------------
Description:
Error below is encountered and queues are not receiving messages.
2021-08-17 07:40:39,394 | ERROR | Caught an Exception adding a message: Message
ID:redacted-365376-16291422903164-7:1:3:1:2070664 dropped=false acked=false
locked=false first to FilePendingMessageCursor |
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor | ActiveMQ
Transport: tcp:///redacted:44604@61616
java.io.IOException: Async Writer Thread Shutdown
at
org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.enqueue(DataFileAppender.java:164)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.storeItem(DataFileAppender.java:129)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.disk.journal.Journal.write(Journal.java:958)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.plist.PListStoreImpl.write(PListStoreImpl.java:444)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.plist.PListImpl.addLast(PListImpl.java:105)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:237)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:157)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:48)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.Topic.dispatch(Topic.java:775)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:556)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.Topic.send(Topic.java:484)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:505)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:459)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:293)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:572)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.8.jar:5.15.8]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_232]
was:
Error below is encountered and queues are not receiving messages.
2021-08-17 07:40:39,394 | ERROR | Caught an Exception adding a message: Message
ID:ucaprdttm04.hq.tnb.com.my-36576-1629142903164-7:1:3:1:2070664 dropped=false
acked=false locked=false first to FilePendingMessageCursor |
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor | ActiveMQ
Transport: tcp:///10.216.120.100:44604@61616
java.io.IOException: Async Writer Thread Shutdown
at
org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.enqueue(DataFileAppender.java:164)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.storeItem(DataFileAppender.java:129)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.disk.journal.Journal.write(Journal.java:958)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.plist.PListStoreImpl.write(PListStoreImpl.java:444)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.store.kahadb.plist.PListImpl.addLast(PListImpl.java:105)[activemq-kahadb-store-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:237)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:157)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:48)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.Topic.dispatch(Topic.java:775)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:556)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.Topic.send(Topic.java:484)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:505)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:459)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:293)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:572)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)[activemq-broker-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233)[activemq-client-5.15.8.jar:5.15.8]
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.8.jar:5.15.8]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_232]
> Getting java.io.IOException: Async Writer Thread Shutdown Error
> ----------------------------------------------------------------
>
> Key: AMQ-8356
> URL: https://issues.apache.org/jira/browse/AMQ-8356
> Project: ActiveMQ (Read-Only)
> Issue Type: Test
> Components: JMS client
> Affects Versions: 5.15.8
> Reporter: Denmark Juance
> Priority: Critical
>
> Error below is encountered and queues are not receiving messages.
>
> 2021-08-17 07:40:39,394 | ERROR | Caught an Exception adding a message:
> Message ID:redacted-365376-16291422903164-7:1:3:1:2070664 dropped=false
> acked=false locked=false first to FilePendingMessageCursor |
> org.apache.activemq.broker.region.cursors.FilePendingMessageCursor | ActiveMQ
> Transport: tcp:///redacted:44604@61616
> java.io.IOException: Async Writer Thread Shutdown
> at
> org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.enqueue(DataFileAppender.java:164)[activemq-kahadb-store-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.store.kahadb.disk.journal.DataFileAppender.storeItem(DataFileAppender.java:129)[activemq-kahadb-store-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.store.kahadb.disk.journal.Journal.write(Journal.java:958)[activemq-kahadb-store-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.store.kahadb.plist.PListStoreImpl.write(PListStoreImpl.java:444)[activemq-kahadb-store-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.store.kahadb.plist.PListImpl.addLast(PListImpl.java:105)[activemq-kahadb-store-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.tryAddMessageLast(FilePendingMessageCursor.java:237)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:157)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:48)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.Topic.dispatch(Topic.java:775)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:556)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.Topic.send(Topic.java:484)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:505)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:459)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:293)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:572)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768)[activemq-client-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)[activemq-broker-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125)[activemq-client-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301)[activemq-client-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233)[activemq-client-5.15.8.jar:5.15.8]
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.8.jar:5.15.8]
> at java.lang.Thread.run(Thread.java:748)[:1.8.0_232]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
