can you post the xml configuration of the broker, it looks like the
temp directory does not exist or does not resolve. It should be based
of the dataDirectory attribute if that is specified.
On 2 September 2011 16:09, nrichards <jricha...@arrisi.com> wrote:
> 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.
>
--
http://fusesource.com
http://blog.garytully.com
