Possible issue with Queue.start()

Hi, I have been looking in an application using ActiveMQ and have a situation where a producer is blocked with this log message due to the temp usage limit being hit: [ActiveMQ Transport: tcp:///aaa.bbb.ccc.ddd:65119@64759] 82567721 INFO org.apache.activemq.broker.region.Queue - Usage(Main:temp:q

Re: QueueSize == 0 && CursorMemoryUsage > 0 - is that a problem?

Hi Tim and Christopher, > It does sound like a bug, and it certainly could be the same root > cause as the bug you linked to. Does the workaround in that bug also > work (temporarily) for you? I can't really apply that workaround to our application (deleting the queue and re-creating it) I'm afra

QueueSize == 0 && CursorMemoryUsage > 0 - is that a problem?

Hi, I have an application using ActiveMQ 5.13.5 which uses non-persistent messages. There is a queue which has several producers and a single consumer. At times I see the CursorMemoryUsage not being 0 despite the queue being empty. When this application runs for a very long time, CursorMemoryUs

Re: Performance issue in OrderedPendingList

> On Sat, Nov 28, 2015 at 2:25 AM, Claus Ibsen > wrote: > > > Yeah I agree. > > > > I just wonder if that loop was using equals and not comparing just the > > message id, maybe there was a purpose of the old code. But a git blame > > can maybe tell us more. &g

Re: Performance issue in OrderedPendingList

ea is to log a JIRA ticket about this > > so its not forgotten and so the AMQ team can look at it and get it > > into the next release. > > > > On Fri, Nov 27, 2015 at 2:39 AM, David Sitsky > > wrote: > > > FWIW I changed the contains method as follows: >

Re: Performance issue in OrderedPendingList

this change in to the upcoming 5.13 release? On Thu, Nov 26, 2015 at 11:44 AM, David Sitsky wrote: > Hi, > > I have updated my application from ActiveMQ 5.3 to 5.11.1 and have noticed > a performance degregation issue. Running a number of jstacks I can see the > broker is o

Performance issue in OrderedPendingList

Hi, I have updated my application from ActiveMQ 5.3 to 5.11.1 and have noticed a performance degregation issue. Running a number of jstacks I can see the broker is often stuck here: "Queue:master-items" Id=122 RUNNABLE at org.apache.activemq.broker.region.cursors.OrderedPendingList.contains(Orde

Re: InFlightCount/DispatchCount meaning

2009/6/19 Denis Bazhenov : > I'm interested in following topic. What does the InFlightCount mean if > JMX console for queue. > > It's seems like in flight count is difference between dequeue count and > dispatch count. But I have very strange situation. > > I have a queue which have following stati

Re: onMessage() synchronisation requirements for queue+topic consumer

For the record, Rob has fixed this issue described in AMQ-2025 and I have confirmed it seems to have fixed things. Cheers, David David Sitsky <[EMAIL PROTECTED]> writes: > Hi Rob, > > Thanks for your reply. It turns out I already set this property to true > for both the bro

Re: onMessage() synchronisation requirements for queue+topic consumer

q.UseDedicatedTaskRunner=true for your client > instead of the synchronized onMessage() - and let me know if it > behaves correctly ? > > > cheers, > > Rob > > Rob Davies > http://fusesource.com > http://rajdavies.blogspot.com/ > > > > On 1 Dec 2008, at 09

onMessage() synchronisation requirements for queue+topic consumer

Hi, I think this might be an easy question, but I have an application where my onMessage() handler is a consumer for both topic and queue messages. The topic and queue consumer are derived from the same ActiveMQ session, so I was under the impression that my onMessage() handler would not be calle

Re: receive() does not throw exception when activemq.bat is terminated

I'm quite a new user to ActiveMq and it's queuing system but as I have understood it the: receive(5000) or receive() (I've also tried receiveNoWait()) should both throw an exception if they are run when the activemq.bat has been terminated. Have a look at the Connection.setExceptionListener(Exc

Re: optimizedAcknowledge flag with performance issue

Have you tried using different prefetch sizes for your queues? I imagine in your application, this could make a big difference too. Cheers, David zaoliu wrote: I set the optimizedAcknowledge flag in the consumer client to patch the knowledge for boosting performance by following the link belo

Re: Duplicate messages sent to Queue after broker restarts

ryarger wrote: I am running the 5.1 SNAPSHOT from 2/19 (have also used 2/12) and I am noticing that messages are being resubmitted to queues after a broker restart. I have tried persisting to both the AMQ Store and to SQL Server. The issue occurs for both. I am using Spring's DefaultMessageListen

Using FilePendingQueueMessageStoragePolicy for non-persistent messaging

Hi, I want to use FilePendingQueueMessageStoragePolicy in my application since I don't use persistent messaging, but I don't want to be limited by memory as to the number of queued messages that are outstanding, which for my application might be very large, depending on the data being process

Re: Message dispatch performance using ActiveMQ 5 on application using 4 quad-cores machines

full stack trace ? thanks, Rob On Dec 20, 2007, at 6:55 AM, David Sitsky wrote: Hi, I have simplistically speaking, an application using ActiveMQ 5 which has a queue called work-items. A master JVM process puts work items onto the queue (this process also runs the embedded JMS broker)

Message dispatch performance using ActiveMQ 5 on application using 4 quad-cores machines

Hi, I have simplistically speaking, an application using ActiveMQ 5 which has a queue called work-items. A master JVM process puts work items onto the queue (this process also runs the embedded JMS broker), and external worker JVM processes read these items using receive() with a timeout of

Re: Duplicate message delivered to consumers on queue with AMQ persistence

;ll try to find some time in the next week or so to produce a unit test which will hopefully show the issue. Cheers, David David Sitsky wrote: Hi Rob, Sorry to hear that - I've also spent ages. FWIW, it happens regardless of the value for persistentIndex, I've used both true and f

Re: Duplicate message delivered to consumers on queue with AMQ persistence

eal application to see if I can reproduce it. Cheers, David Rob Davies wrote: Hi Dave, spent ages trying to reproduce this with no luck - anybody else had luck reproducing this on the latest? cheers, Rob http://rajdavies.blogspot.com/ On Oct 9, 2007, at 6:28 AM, David Sitsky wrote:

Duplicate message delivered to consumers on queue with AMQ persistence

heers, David David Sitsky wrote: Hi Rob, Yes - I haven't seen the issue in my application since updating. Many thanks again. Cheers, David Rob Davies wrote: Hi David, I had a test case that periodically could reproduce this - it now can't after ensuring references are always fres

Re: RecoveryListenerAdapter - Message id ID... could not be recovered from the data store: WAS: [Duplicate message delivered to consumers on queue with kaha persistence]

e part of AMQ Store. Is your application now fixed? thanks, Rob On Oct 8, 2007, at 2:48 AM, David Sitsky wrote: Hi Rob, Looks like you have fixed this issue - many thanks. Cheers, David Rob Davies wrote: Hi David, I've had a look through the log you've attached to AMQ-1445 - bu

Re: RecoveryListenerAdapter - Message id ID... could not be recovered from the data store: WAS: [Duplicate message delivered to consumers on queue with kaha persistence]

ttempt to retrieve a message that's already been deleted - I just need to find out why ;) Could I trouble you to try and devise a junit test case to reproduce? thanks, Rob On Oct 5, 2007, at 7:37 AM, David Sitsky wrote: Hi Rob, I think I spoke too soon. While using AMQ store fixed

Correct way to call/access VMTransport.setAsyncQueueDepth() from BrokerService?

I have an application which runs the embedded broker, and adds both the TCP and the VM transports. In my experiments, I noticed I needed to modify VMTransport.asyncQueueDepth to be larger than the default value of 2000. I noticed this field has a setAsyncQueueDepth() method, but it is not cl

RecoveryListenerAdapter - Message id ID... could not be recovered from the data store: WAS: [Duplicate message delivered to consumers on queue with kaha persistence]

store! I created a JIRA record which contains the detailed debug message logs: https://issues.apache.org/activemq/browse/AMQ-1445 FWIW, JDBC persistence works fine. Any ideas what might be wrong? Cheers, David David Sitsky wrote: Hi Rob, Looks like the AMQ store works correctly - thanks for

Default value for syncOnWrite for AMQ store should be true?

I have noticed that the default value for syncOnWrite for the AMQ store is set to false. Is this a wise default? As a user of a transactional messaging store, I would have thought the common expectation would be that if my broker dies, all messages in committed transactions have been safely w

Re: Duplicate message delivered to consumers on queue with kaha persistence

, David Sitsky wrote: I have discovered an issue with the latest activemq 5.0 (revision 581510) which seems to have been present for some time, at least for the last month. I have an application using transactions, and kaha persistence, and two consumers feeding off a queue. I sometimes see

Duplicate message delivered to consumers on queue with kaha persistence

I have discovered an issue with the latest activemq 5.0 (revision 581510) which seems to have been present for some time, at least for the last month. I have an application using transactions, and kaha persistence, and two consumers feeding off a queue. I sometimes see the same message being

Re: Large PendingQueueSize values for subscriptions on a queue with one message

ing I have done wrong. Cheers, David Rob Davies wrote: could you build a junit test case to demonstrate this ? This would be most hopeful cheers, Rob 'Go Get Integrated - ride the Camel! - http://activemq.apache.org/camel/' http://rajdavies.blogspot.com/ On Aug 23, 2007, at 9

Large PendingQueueSize values for subscriptions on a queue with one message

I have an application which is using the latest snapshot of ActiveMQ 5.0. I have a master JVM process which sends an item to a work-item queue. I have worker JVM processes which pick up these items, process them, and possibly create new items into the work-item queue as a part of processing t

Re: Embedded broker with TCP transport not message dispatching to all consumers in round-robin fashion

Turns out this was a silly application bug - nothing to do with activemq after all. My apologies. Cheers, David David Sitsky wrote: Hi, I am sure this is a silly configuration issue on my part, but I can't figure it out. I am using activemq 4.1.1 on Vista. I basically have two q

Embedded broker with TCP transport not message dispatching to all consumers in round-robin fashion

Hi, I am sure this is a silly configuration issue on my part, but I can't figure it out. I am using activemq 4.1.1 on Vista. I basically have two queues, one called submitted-items, and another called completed-items. JVM1 takes items from completed-items, and does some work with them. Th