Re: JAVA ActiveMQ JMX browse messages on Topic

2017-08-18 Thread Tim Bain
By the way, there's an ongoing thread ( http://activemq.2283324.n4.nabble.com/Delete-Purge-Topic-tp4728932.html) about whether it's possible to use the JMX delete action on the topic to effectively purge the existing messages from the topic. I'd be curious whether you hit the same issues that that

Re: JAVA ActiveMQ JMX browse messages on Topic

2017-08-18 Thread Tim Bain
You can browse queues, but not topics. Tim On Aug 18, 2017 12:15 PM, "Hitesh" wrote: > Hi all, > > The following question is for ActiveMQ 5.13. > > I have 2 durable subscribers listening to a topic, lets say ExampleTopic. > I need to delete all the messages on that topic when a particular event

Re: Close message listener decoupled

2017-08-18 Thread Justin Bertram
> I can't see any reason why anyone would ever not want to use ActiveMQ ;) I agree. However, based on his code he's using 5.x right now, and I can imagine a day when he'd want to move to ActiveMQ Artemis. :) Justin On Fri, Aug 18, 2017 at 1:59 PM, Timothy Bish wrote: > On 08/18/2017 02:49

Re: Close message listener decoupled

2017-08-18 Thread Timothy Bish
On 08/18/2017 02:49 PM, Justin Bertram wrote: I see a couple of potential problems with this code: 1) It's littered with non-JMS code (e.g. ActiveMQConnectionFactory, ActiveMQConnection). You may not care about that if this application will only ever integrate with ActiveMQ, but if you think yo

Re: Close message listener decoupled

2017-08-18 Thread Justin Bertram
I see a couple of potential problems with this code: 1) It's littered with non-JMS code (e.g. ActiveMQConnectionFactory, ActiveMQConnection). You may not care about that if this application will only ever integrate with ActiveMQ, but if you think you'll ever want to use any other kind of JMS brok

JAVA ActiveMQ JMX browse messages on Topic

2017-08-18 Thread Hitesh
Hi all, The following question is for ActiveMQ 5.13. I have 2 durable subscribers listening to a topic, lets say ExampleTopic. I need to delete all the messages on that topic when a particular event occurs. I tried to find the jolokia apis to do the same but couldn't find any. So I've decided to

Re: Close message listener decoupled

2017-08-18 Thread Juleian
That sounds reasonable actually. The only problem I also somehow have is when register is called the method "is stuck" in the thread that is opened or not? I do not see how I can return a value with this structure (maybe the strcture is not good at all, its my first real programming task). public

Re: Close message listener decoupled

2017-08-18 Thread Justin Bertram
The problem you've described is pretty vague and open-ended in my opinion. It's hard to give any advice in such a situation, but here's a thought... You could have register() return the javax.jms.MessageConsumer on which the message listener is set so when you want to close it you can just call Me

Close message listener decoupled

2017-08-18 Thread Juleian
We want to use ActiveMQ within a tool for JMS communication. I wrote a class containing a method that handles the subscription to the broker with a certain topic. So by using my register(topic) method, a message listener is created that listens to the topic mentioned in the parameter. This register

Apache.NMS.Stomp 1.7?

2017-08-18 Thread andrewerc
Can we get an official release of nms stomp 1.7? The erpo has been sitting at v1.7 in git for 2 years, but the downloads page only has v1.5.4. Apache.NMS.Stomp 1.5.4 is incompatable with Apache.NMS 1.7 making it difficult to support multiple protocols in the same project. -- View this message

Re: Temp Store is Full - False Positive?

2017-08-18 Thread khandelwalanuj
I am a bit confused here. Few questions, 1. Even if we are using levelDB for persistent store, does temp store is still kahadb ? 2. What is the location of temp store, is it same as levelDB store or something else ? (Similar question I asked http://activemq.2283324.n4.nabble.com/ActiveMQ-Temp-Sto

Re: Temp Store is Full - False Positive?

2017-08-18 Thread Tim Bain
By "persistent store," did you really mean "temp store"? If what you gave is the persistent store (LevelDB, according to your other post), that wasn't what I was asking for, and I meant the size of the KahaDB-backed temp store. On Aug 18, 2017 7:09 AM, "khandelwalanuj" wrote: > My configuration

Re: Delete/Purge Topic

2017-08-18 Thread Tim Bain
On Aug 17, 2017 7:39 AM, "meghaauti" wrote: Hi I am sorry there was a mistake in the previous question Using jolokia api I am able to delete a topic but when topic(with the same name that was deleted) is again created somehow subscribers are not getting registered. Do they re-subscribe if you

Re: Temp Store is Full - False Positive?

2017-08-18 Thread khandelwalanuj
My configuration is: When this happened the size of persistent store was ~250 MB -- View this message in context: http://activemq.2283324.n4.nabble.com/Temp-Store-is-Full-False-Positive-tp4695836p4729806.html Sent from the ActiveMQ - U

Re: Temp Store is Full - False Positive?

2017-08-18 Thread Tim Bain
When this happens, how much disk space is used for KahaDB data files for the temp store? And what temp store limit are you using? Tim On Aug 16, 2017 1:29 AM, "khandelwalanuj" wrote: > Hi, > > We have also faced the same issue with ActiveMQv5.14.5 recently couple of > time and as you mentioned