Re: ActiveMQ broker discards messages for topic durable subscriber if they were sent to topic while client was offline due to unexpecteable lost connection

Nice work, HappyMan -- glad to help! -Justin On 10/22/19, 2:38 AM, "HappyMan" wrote: Hi, Justin. I turned on InactivityMonitor and now everything works great. I set keepAlive interval in MQTT client for 10 seconds and defaultKeepAliveInterval on MQTT transport connectot in

Re: ActiveMQ broker discards messages for topic durable subscriber if they were sent to topic while client was offline due to unexpecteable lost connection

Hi HappyMan, You're welcome! That's good to know -- I figured the InactivityMonitor was enabled, good to know that it was disabled. Enabling it will help I'm sure, you might need to tweak some of the timeout values, etc, but, good luck and keep us posted! -Justin On 10/21/19, 3:30 PM, "Hap

Re: ActiveMQ broker discards messages for topic durable subscriber if they were sent to topic while client was offline due to unexpecteable lost connection

Hi HappyMan, So, architecturally speaking, this is really something that should be handled at the client/application layer using your exception handling and try/catch/finally logic. Your code should never be allowed to crash without releasing the connection, even with a hard kill of the proces

Re: Active MQ Shared File System Master Slave with Elastic File System

Thanks Tim! I recently posted a blog article on this subject, if the user community would like some details about the pluggable storage locker implementation: http://blog.klocwork.com/open-source/pluggable-storage-lockers-for-activemq/ I hope it’s helpful. -Justin On 9/2/16, 11:53 PM, "tbai

Re: Active MQ Shared File System Master Slave with Elastic File System

Be careful of this, in my own load testing the lock state can be lost over EFS leading to a “master-master” scenario under heavy load, which can lead to journal corruption. Check out the lease locking pluggable storage locker, which is a viable workaround for this problem. Thanks, Justin On

Re: Storing message off heap, message compression, and storing the whole message as headers.

"You made a statement that sounds like "the JVM can only use half its memory, because the other half has to be kept free for GCing", which doesn't match my experience at all. I've observed G1GC to successfully GC when the heap was nearly 100% full, I'm certain it's not a problem for CMS because CM

Re: Queue locks up , purging it allows it to work again.

Have you tried forcing prefetch to 1 as a destination policy? -Justin On Apr 19, 2015 8:15 PM, Kevin Burton wrote: I’m totally stumped on this bug …. Essentially, I have a queue that locks up and consumers in my main daemon no longer consume messages from it. It’s basically dead. If I restar

Re: determining the host that consumed/produced a message?

Hi Kevin, For setting a custom ID, use the oft-overlooked ActiveMQConnection / Connection setClientID() method. Just be sure to use a unique one per client, ActiveMQ will reject dupes. I haven¹t used Advisories for that before, but, setClientID is really useful for inventory. Thanks, Justin On

Re: Commercial Support Page

ours or so. > >Please review and let us know if you have any questions. > >Regards, >Hadrian > >[1] https://cwiki.apache.org/confluence/display/ACTIVEMQ/Support > > >On 01/26/2015 03:01 PM, Justin Reock wrote: >> Hi Hadrian, >> >> Thanks for your hel

Re: Commercial Support Page

st the >text you're proposing? > >Cheers, >Hadrian > > >On 01/26/2015 10:01 AM, Justin Reock wrote: >> Hi ActiveMQ community, >> >> I'm wondering who I would need to get in touch with to improve the >>verbiage on ActiveMQ's Commercial Support

Commercial Support Page

onal Contracting, On-Site Training, and 24x7 Professional and Developer support. Please let me know whom I can contact to improve our representation on that page. I spoke with the Apache webmaster, Mike Drob, and he directed me here to the User List. Thanks, Justin Reock Open Source Solu

Apache Shiro for SSL in ActiveMQ

Hi all, I was looking through the available filters for Apache Shiro in 5.10, and I didn't see an SSLFilter available. Does this mean that, currently, Apache Shiro cannot be used to manage the SSL transport connector in ActiveMQ? If it can be used and I'm just overlooking something, is there a

Re: Jetty Security Web Console

Hi Troy, Please reference the following JIRA: https://issues.apache.org/jira/browse/AMQ-5388 The workaround will show you how to limit access for a set of users. The default configuration, as you noted, grants the same access to Admins and regular users, but you can alter this to lock it down pr

HawtIO ActiveMQ Plugin - ConstraintMapping

Hi all, I'm attempting to set up ConstraintMapping in jetty.xml for non-admin users against jolokia/HawtIO. I'm having trouble tracking down the actual URLs that are used to do create/write/delete operations. Where can I find the HawtIO source code for the ActiveMQ plugin? Or, even better, h

Re: Replicated LevelDB store issues

Remove the ³pax-url-aether-1.5.2.jar² from /lib to resolve this issue. Thanks, Justin Reock OpenLogic Www.openlogic.com On 9/23/14, 12:31 PM, "Kevin Burton" wrote: >Š and I seem to recall that I fixed this and had to rm a jar or move it to >a specific directory. But I¹ve long