Re: [Artemis] Detect slow consumers stop being slow

s://github.com/art-licis/activemq-jmx-monitor). I know I could use > > notifications, but I needed JMX anyway to update list of outstanding slow > > consumers and detect when they are not slow anymore. > > > > Now, there's a question on how I do it with Artemis? I can onl

Re: [Artemis] Detect slow consumers stop being slow

https://github.com/art-licis/activemq-jmx-monitor). I know I could use > notifications, but I needed JMX anyway to update list of outstanding slow > consumers and detect when they are not slow anymore. > > Now, there's a question on how I do it with Artemis? I can only detect slow &g

[Artemis] Detect slow consumers stop being slow

s (if anyone interested, it's on a github: https://github.com/art-licis/activemq-jmx-monitor). I know I could use notifications, but I needed JMX anyway to update list of outstanding slow consumers and detect when they are not slow anymore. Now, there's a question on how I do it with Arte

Re: Slow consumers not detected with ?consumer.prefetchSize=1

Yep, for 2, 3, 4, ... (i.e., smaller than producer produces ahead); for 1 it doesn't work. In my test there's a constant at the beginning of a class, currently 2. Changing to 1 breaks the test. - Art -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Slow consumers not detected with ?consumer.prefetchSize=1

Does it work for prefetchSize=2, just not 1? (Sorry, I won't be able to try running the code till sometime next week, otherwise I'd just try it myself rather than ask.) Tim On Thu, Aug 31, 2017 at 7:40 AM, art.licis wrote: > I'm sorry, I sent a wrong link; Unit test is here: > https://github.co

Re: Slow consumers not detected with ?consumer.prefetchSize=1

I'm sorry, I sent a wrong link; Unit test is here: https://github.com/art-licis/activemq-jmx-monitor/blob/master/src/test/java/today/jvm/amq/ActiveMQJmxMonitorTest.java If you need a completely independent unit test, that's possible. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-

Slow consumers not detected with ?consumer.prefetchSize=1

Community, I was working on slow consumer/producer blocked monitoring using JMX (yes, I know I can use advisory msgs, but they won't tell when slow consumer stops being slow consumer; also I want to get the big picture right away after monitor starts), and wrote a unit test to trigger slow consume

Re: slow consumers

recommend to prevent the freeze situation? Attached resource usage graph. Note that during 100% memory usage, transmitted network bandwidth went up. [image: Inline image 1] On Sat, Jun 25, 2016 at 9:38 AM, Tim Bain wrote: > I've never seen any code that responds to slow consumers like

Re: slow consumers

I've never seen any code that responds to slow consumers like that. There are a few plugins that allow you to abort (i.e. disconnect) slow consumers, but you have to enable them explicitly and you'd see logging about how the broker was aborting them. Are you using a persistence stor

slow consumers

umers. To come out of this situation, I enable consumers to drop certain kind of messages (to trigger faster consumption). After this change, ActiveMQ starts delivering messages, and queue gets drained. Looks like to me, ActiveMQ detects the slow consumers for a growing queue, and stops deliv

RE: How to detect slow consumers

consumers We have the problem at a customer that our message store is growing all the time in some cases. It might be related to having slow consumers. Is it possible to detect these? For information we are using mainly topics and partly retro active consumer policy in AMQ. We are also using vm

How to detect slow consumers

We have the problem at a customer that our message store is growing all the time in some cases. It might be related to having slow consumers. Is it possible to detect these? For information we are using mainly topics and partly retro active consumer policy in AMQ. We are also using vm Cursor

Re: Are message actually evicted/deleted from a queue on slow consumers?

Nope, slow consumer strategies and pending message limit strategies are orthogonal; messages are discarded because there are two many of them pending and you've configured a pending message limit strategy, not necessarily because consumers are considered slow. (In fact, depending on your settings,

Re: Simple JMX metric for the number of slow consumers?

gt; > > > https://issues.apache.org/jira/browse/AMQ-5624 > > > > > > > > > > > > > > > > On Sun, Mar 1, 2015 at 1:59 PM, Tim Bain > > wrote: > > > > > > > >> This sounds like a useful feature; submit an Enhan

Re: Are message actually evicted/deleted from a queue on slow consumers?

And I can’t tell if it’s saying that messages are evicted from the entire QUEUE or just messages target for that consumer. I’m looking at TopicSubscription to try to figure it out and it’s unclear if it’s just for messages targeted to a specific consumer which are then placed *back* into the queue

Are message actually evicted/deleted from a queue on slow consumers?

Message eviction seems to be not well documented so I’m confused. If I have a slow consumer, does the broker actually *delete* messages? So if I have an errant consumer, configured incorrectly, this will impact production because messages are just removed from the queue? -- Founder/CEO Spinn3

Re: Simple JMX metric for the number of slow consumers?

ar 1, 2015 at 1:59 PM, Tim Bain > wrote: > > > > > >> This sounds like a useful feature; submit an Enhancement in JIRA for > > it... > > >> > > >> Were you looking for a broker-level count (count of slow consumers on > > all > > &

Re: Simple JMX metric for the number of slow consumers?

/browse/AMQ-5624 > > > > > > > > On Sun, Mar 1, 2015 at 1:59 PM, Tim Bain wrote: > > > >> This sounds like a useful feature; submit an Enhancement in JIRA for > it... > >> > >> Were you looking for a broker-level count (count of slow consumers

Re: Simple JMX metric for the number of slow consumers?

o. > > https://issues.apache.org/jira/browse/AMQ-5624 > > > > On Sun, Mar 1, 2015 at 1:59 PM, Tim Bain wrote: > >> This sounds like a useful feature; submit an Enhancement in JIRA for it... >> >> Were you looking for a broker-level count (count of slow consu

Re: Simple JMX metric for the number of slow consumers?

> Were you looking for a broker-level count (count of slow consumers on all > destinations) or a destination-level count? Or both? (Implementing both > seems most useful to me, and not particularly hard to do.) > > Tim > > > > On Sun, Mar 1, 2015 at 2:35 PM, Kevin Burto

Re: Simple JMX metric for the number of slow consumers?

This sounds like a useful feature; submit an Enhancement in JIRA for it... Were you looking for a broker-level count (count of slow consumers on all destinations) or a destination-level count? Or both? (Implementing both seems most useful to me, and not particularly hard to do.) Tim On Sun

Simple JMX metric for the number of slow consumers?

According to this: http://activemq.apache.org/jmx.html There are no simple metrics for the number of slow consumers. Is there an easy way to figure this out? Would be nice for monitoring systems so that alerts can be triggered. Right now you have to enumerate each subscriber but it takes

Re: Not abortable slow consumers / stopped processing of messages in a queue

on what you're seeing. > > Can you give us a from-the-top summary? No need to give the overview or > > any config files or log files, just tell us at each step what you expect > > to > > happen and what's actually happening (and how you know). > > > > A

Re: Not abortable slow consumers / stopped processing of messages in a queue

ching > the > difference between them, but I'm not at all clear on what you're seeing. > Can you give us a from-the-top summary? No need to give the overview or > any config files or log files, just tell us at each step what you expect > to > happen and what's actuall

Re: Not abortable slow consumers / stopped processing of messages in a queue

t at all clear on what you're seeing. Can you give us a from-the-top summary? No need to give the overview or any config files or log files, just tell us at each step what you expect to happen and what's actually happening (and how you know). Also, your first message was all abou

Re: Not abortable slow consumers / stopped processing of messages in a queue

rantees. In our system we could have many bugfix releases throughout the day, and if that would happen and the report wasn’t generated before the restart of the application we would lose the message. I am trying to find a config which will work for us most often automatically and only for

Re: Not abortable slow consumers / stopped processing of messages in a queue

oing or find a way to get your answer with less processing (e.g. by only sampling some of your data). This is obviously very specific to whatever domain you're working in and might not be easy to do, but 18 hours to process a message definitely makes my Spidey senses tingle... Tim On Sun, Oct 26, 2

Not abortable slow consumers / stopped processing of messages in a queue

Hi guys, I am facing a strange problem related to slow consumers that couldn’t been aborted and I couldn’t solve the issue by myself. We have one queue where we process quite heavy operations (report generation). The number of messages per day isn’t too big: usually less than 100. We have to

Re: Slow Consumers in ActiveMQ 5.9

there are two different Strategies On 8 April 2014 11:19, khandelwalanuj wrote: > Hi, > > I was going through https://issues.apache.org/jira/browse/AMQ-4621 > *(AbortSlowAckConsumerStrategy )* > > If I specify this strategy to abort slow consumers in my xml configuration, >

Slow Consumers in ActiveMQ 5.9

Hi, I was going through https://issues.apache.org/jira/browse/AMQ-4621 *(AbortSlowAckConsumerStrategy )* If I specify this strategy to abort slow consumers in my xml configuration, does it also changes the way we consider a consumer slow. Previously we consider a consumer as slow based on the

Re: How to generate slow consumers.

gMessageLimit OR b) no of msgs > prefetchlimit + constantPendingMessageLimit Please help me here. I am getting confused. -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-generate-slow-consumers-tp4672583p4672976.html Sent from the ActiveMQ - User mailing

Re: How to generate slow consumers.

? ) Thanks, John -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-generate-slow-consumers-tp4672583p4672970.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: How to generate slow consumers.

message in context: > http://activemq.2283324.n4.nabble.com/How-to-generate-slow-consumers-tp4672583p4672914.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > -- *Christian Posta* http://www.christianposta.com/blog twitter: @christianposta

Re: How to generate slow consumers.

.nabble.com/How-to-generate-slow-consumers-tp4672583p4672935.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: How to generate slow consumers.

storUsage limit is reached a producer is declared as fast, and it has to slow down ? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-generate-slow-consumers-tp4672583p4672914.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: How to generate slow consumers.

And also consider setting prefetch limits on your consumer lower than defaults. Slow consumers are "slow" relative to how many messages have been dispatched vs their prefetch limit. On Thu, Oct 10, 2013 at 10:02 AM, Robert Davies wrote: > Its going to be difficult to setup a

Re: How to generate slow consumers.

sages asynchronously in blocks of a 1000 or so - and have more than one consumer, and put a blog sleep in one of the consumers (to simulate a slow application). On 10 Oct 2013, at 17:54, johnbing wrote: > Hi, > > I am using ActiveMQ-5.8.0. ActiveMQ internally takes care of handling the > slow

How to generate slow consumers.

Hi, I am using ActiveMQ-5.8.0. ActiveMQ internally takes care of handling the slow consumers. But i have never seen any slow consumer in my broker. I am trying to create a slow consumer but not successful yet -- I have a test application(ping-pong) in which requester sends a message and waits

Re: Dropping slow consumers

ep 12, 2013 at 1:26 PM, Oleg Dulin wrote: > Dear Distinguished Colleagues: > > I would like to be able to drop slow consumers . If a slow consumer is > detected, I want it gone, and I want an advisory message to say "this > consumer was dropped". I can't fi

Re: Dropping slow consumers

, Sep 12, 2013 at 1:26 PM, Oleg Dulin wrote: > Dear Distinguished Colleagues: > > I would like to be able to drop slow consumers . If a slow consumer is > detected, I want it gone, and I want an advisory message to say "this > consumer was dropped". I can'

Re: Dropping slow consumers

Tim Bish suggested you on IRC take a look at ConsumerEventSource: http://activemq.apache.org/maven/apidocs/org/apache/activemq/advisory/ConsumerEventSource.html On Thu, Sep 12, 2013 at 1:26 PM, Oleg Dulin wrote: > Dear Distinguished Colleagues: > > I would like to be able to

Re: Dropping slow consumers

che/activemq/advisory/ConsumerEventSource.html > > > On Thu, Sep 12, 2013 at 1:26 PM, Oleg Dulin wrote: > >> Dear Distinguished Colleagues: >> >> I would like to be able to drop slow consumers . If a slow consumer is >> detected, I want it gone, and I want an advis

Re: Dropping slow consumers

ould like to be able to drop slow consumers . If a slow consumer is > detected, I want it gone, and I want an advisory message to say "this > consumer was dropped". I can't find good documentation for this. Any ideas ? > > -- > Regards, > Oleg Dulin > http://www.olegdulin.com > >

Re: Dropping slow consumers

wrote: > Dear Distinguished Colleagues: > > I would like to be able to drop slow consumers . If a slow consumer is > detected, I want it gone, and I want an advisory message to say "this > consumer was dropped". I can't find good documentation for this. Any ideas ? >

Dropping slow consumers

Dear Distinguished Colleagues: I would like to be able to drop slow consumers . If a slow consumer is detected, I want it gone, and I want an advisory message to say "this consumer was dropped". I can't find good documentation for this. Any ideas ? -- Regards,

Re:Discard messages for Slow consumers on "Queue"

pic(); >// the new config that enables selectors on the intercepter >virtualTopic.setSelectorAware(true); >VirtualDestinationInterceptor interceptor = new >VirtualDestinationInterceptor(); >interceptor.setVirtualDestinations(new VirtualDestination[] { >virtualTopic }); >

Discard messages for Slow consumers on "Queue"

tualDestinationInterceptor(); interceptor.setVirtualDestinations(new VirtualDestination[] { virtualTopic }); broker.setDestinationInterceptors(new DestinationInterceptor[] { interceptor }); broker.start(); -- View this message in context: http://activemq.2283324.n4.nabble.com/Discard-m

Re: Large messages, slow consumers and java heap space

OK, I fear that what's happening is that producer flow control is kicking in, and that camel is taking messages off queues, but it can't put them on queues, so camel is holding all these messages in memory, which will eventually fill up. I don't see why producer flow control would be applied, sin

Re: Large messages, slow consumers and java heap space

On Tue, Mar 8, 2011 at 10:52 AM, Illtud Daniel wrote: > On 08/03/11 09:26, Claus Ibsen wrote: > >> Have you looked at some of the guides at FuseSource about the broker? >> http://fusesource.com/products/enterprise-activemq/#documentation > > No, I'll take a look, thanks. > >> And there is a Active

Re: Large messages, slow consumers and java heap space

On 08/03/11 09:32, Dejan Bosanac wrote: I'd suggest using blob messages for messages of that size: http://activemq.apache.org/blob-messages.html Unfortunately, we've already architected the processes around xml payload messages, so we've got camel picking some info from the messages with xpath

Re: Large messages, slow consumers and java heap space

On 08/03/11 09:26, Claus Ibsen wrote: Have you looked at some of the guides at FuseSource about the broker? http://fusesource.com/products/enterprise-activemq/#documentation No, I'll take a look, thanks. And there is a ActiveMQ in Action book to be published this month. Maybe it has some det

Re: Large messages, slow consumers and java heap space

Hi, I'd suggest using blob messages for messages of that size: http://activemq.apache.org/blob-messages.html Regards -- Dejan Bosanac - FuseSource - The experts in open source integration and messaging. Email: dej...@fusesource.com W

Re: Large messages, slow consumers and java heap space

On Tue, Mar 8, 2011 at 10:15 AM, Illtud Daniel wrote: > On 07/03/11 18:19, Illtud Daniel wrote: > >> I've attempted to read everything I can about producer flow control, >> message cursors, prefetch limits, etc. and I still can't get it >> to do what I want. I don't care about speed at all, I have

Re: Large messages, slow consumers and java heap space

On 07/03/11 18:19, Illtud Daniel wrote: I've attempted to read everything I can about producer flow control, message cursors, prefetch limits, etc. and I still can't get it to do what I want. I don't care about speed at all, I have plenty of disk space, and all messages are persistent. Anybood

Large messages, slow consumers and java heap space

I'm using stomp, java clients and camel to move messages through a 'pipeline' of activemq queues. The messages can be very big (>120MB) and unfortunately the OS is 32-bit, so I want to keep memory usage to a minimum (2GB limit). There isn't a huge number of messages, but I keep running out of heap

Re: Slow Consumers Advisory Topic not showing

.com > Web: http://fusesource.com > Twitter: http://twitter.com/dejanb > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > > On Fri, Jan 14, 2011 at 1:17 PM, mike.peter.lear > wrote: >> >> Hi any help would be

Re: Slow Consumers Advisory Topic not showing

:  http://twitter.com/dejanb ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Fri, Jan 14, 2011 at 1:17 PM, mike.peter.lear wrote: > > Hi any help would be appreciated. I am having some problems with slow > consumers and wanted to start monitoring the

Slow Consumers Advisory Topic not showing

Hi any help would be appreciated. I am having some problems with slow consumers and wanted to start monitoring them through our monitoring tools. I am using activemq 5.4.0 on windows 7 with java 1.6.0_22. I have a destination policy set in my activemq config

Clarification requested for slow - consumers - matched messages

ge in context: http://old.nabble.com/Clarification-requested-for-slow---consumers---matched-messages-tp27832554p27832554.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Slow consumers slow down fast consumer queue requests

tion.) Thanks a lot! -- View this message in context: http://www.nabble.com/Slow-consumers-slow-down-fast-consumer-queue-requests-tp24563120p24563120.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. -- View this message in context: http://www.nabble.com/Slow-cons

Re: Slow consumers slow down fast consumer queue requests

;>>> really an issue with queues.'' And that the problem occurs almost >>>> instantly >>>> after the slow connection is established, it seems too short for any >>>> memory >>>> usage built-up; and indeed no such problem is

Re: Slow consumers slow down fast consumer queue requests

bserved. We also try >>> twisting >>> ActiveMQ broker and consumer settings like prefetchsize=2000, >>> dedicated task >>> runner = true/false, increase memoryLimit/memoryUsage, >>> optimizedDispatch=true. None seems to solve the problem. >>> &

Re: Slow consumers slow down fast consumer queue requests

false, increase memoryLimit/memoryUsage, > optimizedDispatch=true. None seems to solve the problem. > > What would be the causes and solutions for these scenario? > > (The ActiveMQ site's suggestions of discarding old messages would > create > stale data problems for our applica

Re: Slow consumers slow down fast consumer queue requests

yUsage, >> optimizedDispatch=true. None seems to solve the problem. >> >> What would be the causes and solutions for these scenario? >> >> (The ActiveMQ site's suggestions of discarding old messages would >> create >> stale data problems for our application

Re: Slow consumers slow down fast consumer queue requests

would create stale data problems for our application.) Thanks a lot! -- View this message in context: http://www.nabble.com/Slow-consumers-slow-down-fast-consumer-queue-requests-tp24563120p24563120.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Slow consumers slow down fast consumer queue requests

e seems to solve the problem. What would be the causes and solutions for these scenario? (The ActiveMQ site's suggestions of discarding old messages would create stale data problems for our application.) Thanks a lot! -- View this message in context: http://www.nabble.com/Slow-consumers

Problem with setting memoryUsage when using persistent messaging with slow consumers

rror state? Furthermore, setting prefetch limit to 1000 leads to decrasing of persistent store usage - why is that? Thanks for your help. Regerds, Juraj -- View this message in context: http://www.nabble.com/Problem-with-setting-memoryUsage-when-using-persistent-messaging-with-slow

Re: Cannot get slow consumers to discard messages

; http://fusesource.com > http://rajdavies.blogspot.com/ > > > On 2 Dec 2008, at 05:35, mar1394 wrote: > >> >> I'm using Active MQ 5.0 on a RedHat Linux system. >> >> I have a number of slow consumers in my network, but I cannot get >> the slow >&

Re: Handling of slow consumers

On 11 Dec 2008, at 04:16, Jim Lloyd wrote: I'm trying to better understand what configuration options I can use to handle slow consumers. The slow-consumers<http://activemq.apache.org/slow-consumers.html>page on activemq.apache.org is a little odd. It reads as if it is a br

Handling of slow consumers

I'm trying to better understand what configuration options I can use to handle slow consumers. The slow-consumers<http://activemq.apache.org/slow-consumers.html>page on activemq.apache.org is a little odd. It reads as if it is a brainstorming document, i.e not even at the level of

Re: Cannot get slow consumers to discard messages

your constantPendingMessageLimitStrategy limit property must be greater than 0 thanks, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/ On 2 Dec 2008, at 05:35, mar1394 wrote: I'm using Active MQ 5.0 on a RedHat Linux system. I have a number of slow consumers

Cannot get slow consumers to discard messages

I'm using Active MQ 5.0 on a RedHat Linux system. I have a number of slow consumers in my network, but I cannot get the slow consumer policies to work. I have set the PrefetchSize on the connection URL. java.naming.provider.url=tcp://localhost:61614?connectionTimeout=0&jms.prefetchP

How to: Slow consumers and CLIENT_ACKNOWLEDGE?

ges? Any help would be appreciated. Cheers, Bonny -- View this message in context: http://www.nabble.com/How-to%3A-Slow-consumers-and-CLIENT_ACKNOWLEDGE--tp18356204p18356204.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Slow Consumers and MaximumPendingMessageLimit or MaximumPendingQueueSize?

: what is the difference between > MaximumPendingMessageLimit and MaximumPendingQueueSize? and how can i set > the MaximumPendingQueueSize when subscribing to the topic? > > Regards, > > Saqib > -- View this message in context: http://www.nabble.com/Slo

Re: Monitoring for slow consumers

On 5 May 2008, at 22:08, Badri wrote: Is there any configuration in Active MQ which will detect slow consumers automatically & log any message to the log file? Right now we have been using ./query command to detect slow consumers. Are there any alternatives which will detect

Monitoring for slow consumers

Is there any configuration in Active MQ which will detect slow consumers automatically & log any message to the log file? Right now we have been using ./query command to detect slow consumers. Are there any alternatives which will detect this condition automatically? Are there any configur

Re: performance issues with slow consumers

0826/sar_cpu_mel1u108.sar.sadf.png > http://www.nabble.com/file/p13740826/sar_cpu_mel1u109.sar.sadf.png > http://www.nabble.com/file/p13740826/sar_cpu_mel1u110.sar.sadf.png > http://www.nabble.com/file/p13740826/sar_cpu_mel1u111.sar.sadf.png > http://www.nabble.com/file/p13

Re: performance issues with slow consumers

too - e.g: cheers, Rob http://open.iona.com/ -Enterprise Open Integration http://rajdavies.blogspot.com/ -- View this message in context: http://www.nabble.com/performance-issues-with-slow-consumers-tf4802510s2354.html#a13743744 Sent from the Activ

Re: performance issues with slow consumers

om/file/p13740826/sar_cpu_mel1u113.sar.sadf.png http://www.nabble.com/file/p13740826/activemq.xml activemq.xml -- View this message in context: http://www.nabble.com/performance- issues-with-slow-consumers-tf4802510s2354.html#a13740826 Sent from the ActiveMQ - User mailing list archive at Nabble.com.

performance issues with slow consumers

ttp://www.nabble.com/file/p13740826/sar_cpu_mel1u111.sar.sadf.png http://www.nabble.com/file/p13740826/sar_cpu_mel1u113.sar.sadf.png http://www.nabble.com/file/p13740826/activemq.xml activemq.xml -- View this message in context: http://www.nabble.com/performance-issues-with-slow-consumers-tf48