Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-07 Thread Gary Tully
thanks for the quick validation. Heuston we have a problem! Can you raise a new jira issue to track this, and attach your logs, test case etc. I think it is related to https://issues.apache.org/jira/browse/AMQ-3474 On 7 September 2011 21:35, nrichards wrote: > This exception occurred after about

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-07 Thread nrichards
As did these: 2011-09-07 12:43:40,908 ERROR [cursors.FilePendingMessageCursor] [1315421994681] : [ActiveMQ Transport: tcp:///134.242.171.26:35469] Caught an IO Exception getting the DiskList 7_PendingCursor:snTableQueue_CHF java.lang.NullPointerExceptionnull at org.apache.activemq.store.kahad

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-07 Thread nrichards
This exception occurred after about 1 1/2 hours ... 2011-09-07 12:43:27,057 ERROR [cursors.FilePendingMessageCursor] [] : [Usage Async Task] Caught an IO Exception getting the DiskList7_PendingCursor:snTableQueue_CHF java.lang.NullPointerExceptionnull at java.io.Writer.write(Writer.java:140)nu

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-07 Thread nrichards
I can indeed do that. Was in the middle of building 5.6 from source and wondering how to resolve the activeio-3.2 dependency, but will use what you are pointing to ... thnx. -- View this message in context: http://activemq.2283324.n4.nabble.com/AMQ-5-5-non-persistent-messages-not-processed-cou

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-07 Thread Gary Tully
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/

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-07 Thread nrichards
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

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-02 Thread nrichards
will try the full path. I do see the data directory created in the current working directory of the process and with suitable permissions. -- View this message in context: http://activemq.2283324.n4.nabble.com/AMQ-5-5-non-persistent-messages-not-processed-counted-as-in-flight-tp3776808p3786528.ht

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-02 Thread Gary Tully
give a full path name in dataDirectory="amq-data" to a directory that you know to exist that is accessible by the userid that this context runs under. The temp store will be created on demand and it looks like the NPE is occurring due to some file access problems, using an explicit directory shoul

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-02 Thread nrichards
Thanks for your interest Gary, here's the broker config:

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-02 Thread Gary Tully
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 wrote: > Tuning the OS could be interesting. If you have a specific s

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-02 Thread nrichards
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 get

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-01 Thread Johan Edstrom
I think you need to tune your OS. On Sep 1, 2011, at 3:35 PM, nrichards wrote: > Thanks, I'll add that to the configuration. > > Perhaps this should be different thread, but I'm also using a filecursor to > handle message buffering of non-persistent queue messages and have a large > number of o

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-01 Thread nrichards
The SimpleMessageListenerContainer doesn't have the cacheLevelName property. Are you suggesting returning to the DefaultMessageListenerContainer? -- View this message in context: http://activemq.2283324.n4.nabble.com/AMQ-5-5-non-persistent-messages-not-processed-counted-as-in-flight-tp3776808p378

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-09-01 Thread nrichards
Thanks, I'll add that to the configuration. Perhaps this should be different thread, but I'm also using a filecursor to handle message buffering of non-persistent queue messages and have a large number of occurrences of IO Exceptions get the DiskList, with further messages indicating some kind of

Re: AMQ 5.5 non-persistent messages not processed, counted as in-flight

2011-08-30 Thread Gary Tully
you need to use CACHE_CONSUMER cache level such that there is only a single consumer. On 29 August 2011 18:23, nrichards wrote: > I have a single consumer on each of a number of queues and a prefetch value > of 1, and know that messages will arrive faster than they can be processed. > In each que