activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight
Date Fri, 02 Sep 2011 15:46:31 GMT
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 <jrichartz@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

Mime
View raw message