Re: Dropping slow consumers

2013-09-13 Thread Christian Posta
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 drop slow consumer

ActiveMQ CPP -- setting producerId

2013-09-13 Thread Mark
Hi, Is it possible to set the producerId with ActiveMQ-CPP? If so, how? TIA.

Re: Dropping slow consumers

2013-09-13 Thread Christian Posta
Check here: http://stackoverflow.com/questions/1702755/activemq-consumer-producer-connection-listener On Fri, Sep 13, 2013 at 6:01 AM, Christian Posta wrote: > Tim Bish suggested you on IRC take a look at ConsumerEventSource: > > > http://activemq.apache.org/maven/apidocs/org/apache/activemq/ad

Re: Factory gets no connection with ra package

2013-09-13 Thread travep
Thanks for your input. I can take the working example that hits vm:// and use "tcp://localhost:61616" instead. It works. When I take that same string and configure glassfish to use it I have the same problem. So, I have a broker running on port 61616 but still cannot connect to it with glassfis

Re: NIO transport performance for ActiveMQ

2013-09-13 Thread johnbing
Hi ceposta, I am sorry for this John and Anuj confusion. I was copying and pasting anuj's reply in this thread to get the context and forgot to remove the thanks part. I am not Anuj, don't even know who is the guy. Regarding NIO I am attaching my broker configuration file and thread logs for you

Re: ActiveMQ CPP -- setting producerId

2013-09-13 Thread Timothy Bish
On 09/13/2013 09:17 AM, Mark wrote: Hi, Is it possible to set the producerId with ActiveMQ-CPP? If so, how? TIA. Producer ID is set by the client using a format that's required for proper operation with the AMQ broker, you can't change it. -- Tim Bish Sr Software Engineer | RedHat Inc. t

Re: useJmx=false, two brokers, getting exception due to jmx

2013-09-13 Thread ariskk
yes, I can see it in the log file (& code ofcourse) -- View this message in context: http://activemq.2283324.n4.nabble.com/useJmx-false-two-brokers-getting-exception-due-to-jmx-tp4671456p4671476.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: useJmx=false, two brokers, getting exception due to jmx

2013-09-13 Thread ariskk
And in fact they use different storage directories which is visible in the logs -- View this message in context: http://activemq.2283324.n4.nabble.com/useJmx-false-two-brokers-getting-exception-due-to-jmx-tp4671456p4671477.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Dropping slow consumers

2013-09-13 Thread Torsten Mielke
Hi Oleg, You may also be interested in this post http://timbish.blogspot.de/2013/07/coming-in-activemq-59-new-way-to-abort.html Regards, Torsten Mielke tmie...@redhat.com tmielke.blogspot.com On Sep 12, 2013, at 10:26 PM, Oleg Dulin wrote: > Dear Distinguished Colleagues: > > I would like t

Re: Dropping slow consumers

2013-09-13 Thread Torsten Mielke
I am not aware of any such mechanism you're looking for but perhaps these message limit strategies can help you instead http://activemq.apache.org/slow-consumer-handling.html Regards, Torsten Mielke tmie...@redhat.com tmielke.blogspot.com On Sep 12, 2013, at 10:26 PM, Oleg Dulin wrote: > Dear

Re: Delayed messages not delivered when master goes down.

2013-09-13 Thread Torsten Mielke
Hello Lu, This sounds like a bug to me. Can you please create a JUnit test and raise a bug report? Regards, Torsten Mielke tmie...@redhat.com tmielke.blogspot.com On Sep 11, 2013, at 11:01 PM, rushalias wrote: > Here is my setup > > I have a master/slave (apache-activemq-5.8.0) configura

Re: Interceptors/Phases like in Apache CXF

2013-09-13 Thread Christian Posta
This is pretty cool, might want to check it out too: http://rajdavies.blogspot.com/2013/09/apache-camel-broker-component-for.html On Thu, Sep 12, 2013 at 7:14 AM, Torsten Mielke wrote: > Yes there are interceptors in ActiveMQ. > In AMQ land I don't think we distinguish between interceptors and