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 Wed, 07 Sep 2011 17:12:28 GMT
on the NPE, can you validate your use case with the current
5.6-SNAPSHOT[1], that will prove that your issue is related and
resolved.
The end of the month is the current target for a 5.6 release.

[1] https://repository.apache.org/content/repositories/snapshots/org/apache/activemq/apache-activemq/5.6-SNAPSHOT/

On 7 September 2011 17:04, nrichards <jrichartz@arrisi.com> wrote:
> Generally things are working, except for an intermittent NPE associated with
> accessing the PList in the FileCursor, such as the following. This
> apparently results in a lost message.
>
> I am currently working under the assumption this is related to the known
> issue https://issues.apache.org/jira/browse/AMQ-3434.
>
> Does this seem correct? Is there an estimate of when this fix might be
> available?
>
> 2011-09-03 09:17:40,166 ERROR [cursors.FilePendingMessageCursor] [] : Caught
> an IO Exception getting the DiskList 7_PendingCursor:S_TableQueue_CHF
> java.lang.NullPointerExceptionnull
>    at
> org.apache.activemq.store.kahadb.plist.PListStore$1.execute(PListStore.java:212)null
> at org.apache.kahadb.page.Transaction.execute(Transaction.java:728)null
>    at
> org.apache.activemq.store.kahadb.plist.PListStore.getPList(PListStore.java:208)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
> org.apache.activemq.store.kahadb.plist.PListStore$1.execute(PListStore.java:212)
>
>    at org.apache.kahadb.page.Transaction.execute(Transaction.java:728)
>
>    at
> org.apache.activemq.store.kahadb.plist.PListStore.getPList(PListStore.java:208)
>
>    at
> org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.getDiskList(FilePendingMessageCursor.java:442)
>        ... 6 more
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/AMQ-5-5-non-persistent-messages-not-processed-counted-as-in-flight-tp3776808p3796511.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
http://fusesource.com
http://blog.garytully.com

Mime
View raw message