Tuning the OS could be interesting. If you have a specific suggestion about
the OS tuning, I'll certainly pursue it.
here's an example of one of the IO exceptions, followed by a PList.size()
exception
2011-09-02 05:44:18,863 ERROR [cursors.FilePendingMessageCursor] [] : Caught
an IO Exception getting the DiskList 7_PendingCursor:FACTS
java.lang.NullPointerExceptionnull
at java.io.UnixFileSystem.resolve(UnixFileSystem.java:92)null
at java.io.UnixFileSystem.resolve(UnixFileSystem.java:118)null
at java.io.File.getCanonicalPath(File.java:559)null
at java.io.File.getCanonicalFile(File.java:583)null
at java.io.File.mkdirs(File.java:1189)null
at org.apache.activemq.util.IOHelper.mkdirs(IOHelper.java:249)null
at
org.apache.activemq.store.kahadb.plist.PListStore.intialize(PListStore.java:250)null
at
org.apache.activemq.store.kahadb.plist.PListStore.getPList(PListStore.java:203)null
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.getDiskList(FilePendingMessageCursor.java:442)null
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.flushToDisk(FilePendingMessageCursor.java:423)null
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.onUsageChanged(FilePendingMessageCursor.java:381)null
at org.apache.activemq.usage.Usage$1.run(Usage.java:268)null
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)null
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)null
at java.lang.Thread.run(Thread.java:619)null Exception in thread "Usage
Async Task" java.lang.RuntimeException: java.lang.NullPointerException
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.getDiskList(FilePendingMessageCursor.java:445)
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.flushToDisk(FilePendingMessageCursor.java:423)
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.onUsageChanged(FilePendingMessageCursor.java:381)
at org.apache.activemq.usage.Usage$1.run(Usage.java:268)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.lang.NullPointerException
at java.io.UnixFileSystem.resolve(UnixFileSystem.java:92)
at java.io.UnixFileSystem.resolve(UnixFileSystem.java:118)
at java.io.File.getCanonicalPath(File.java:559)
at java.io.File.getCanonicalFile(File.java:583)
at java.io.File.mkdirs(File.java:1189)
at org.apache.activemq.util.IOHelper.mkdirs(IOHelper.java:249)
at
org.apache.activemq.store.kahadb.plist.PListStore.intialize(PListStore.java:250)
at
org.apache.activemq.store.kahadb.plist.PListStore.getPList(PListStore.java:203)
at
org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.getDiskList(FilePendingMessageCursor.java:442)
... 6 more
2011-09-02 07:46:45,975 DEBUG [TransportConnection.Service] [] : Error
occured while processing async command: ActiveMQObjectMessage {commandId =
769, responseRequired = false, messageId =
ID:lagavulin-61712-1314899305643-0:42:1:1:765, originalDestination = null,
originalTransactionId = null, producerId =
ID:lagavulin-61712-1314899305643-0:42:1:1, destination =
queue://starnodeTableQueue_CM_HOUR_FACTS, transactionId = null, expiration =
0, timestamp = 1314974805813, arrival = 0, brokerInTime = 1314974805858,
brokerOutTime = 0, correlationId = null, replyTo = null, persistent = false,
type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.By
teSequence@a167b9, marshalledProperties =
org.apache.activemq.util.ByteSequence@a0a822, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = {TO=0, FROM=32,
HOST=134.242.171.26, trigger_name=TriggerData, version=3.4},
readOnlyProperties = false, readOnlyBody = false, droppable = false},
exception: java.lang.NullPointerException java.lang.NullPointerExceptionnull
at
org.apache.activemq.store.kahadb.plist.PListStore.size(PListStore.java:193)null
at org.apache.activemq.usage.TempUsage.retrieveUsage(TempUsage.java:53)null
at org.apache.activemq.usage.Usage.caclPercentUsage(Usage.java:240)null
at org.apache.activemq.usage.Usage.isFull(Usage.java:117)null
at org.apache.activemq.usage.Usage.isFull(Usage.java:113)null
at org.apache.activemq.usage.Usage.isFull(Usage.java:109)null
at org.apache.activemq.broker.region.Queue.checkUsage(Queue.java:750)null
at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:674)null
at org.apache.activemq.broker.region.Queue.send(Queue.java:653)null
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365)null
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:523)null
at org.apache.activemq.brokerBrokerFilter.send(BrokerFilter.java:129)null
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)null
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:227)null
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)null
at
org.apache.activemq.security.AuthorizationBroker.send(AuthorizationBroker.java:192)null
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)null
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)null
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:458)null
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681)null
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)null
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)null
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)null
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)null
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)null
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)null
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)null
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)null
at java.lang.Thread.run(Thread.java:619)null
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-5-5-non-persistent-messages-not-processed-counted-as-in-flight-tp3776808p3786303.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
