Clustered Activemq replicated LevelDB via zookeeper + apache camel causes activemq to hang

*Problem:* I have a clustered activemq failover setup, via zookeeper and leveldb (configurations are below). My java application (lets call it pipeline) talks to this cluster via apache camel. Pipeline has both producer and consumer endpoints. (About 10 different queue destinations). In a non-clu

Websocket + MQTT + NIO: Scaling

I am using the mqttws31.js library in a HTML page to connect to ActiveMQ using the websocket transport which uses MQTT. While doing some testing with multiple clients (about 500 connections so far), I noticed the number of thread is growing to over 500, so I assume there is one thread per connectio

Re: ActiveMQ 5.9.1 +MQTT

Hey Rob, Sure. I will create JIRA for the same. Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-5-9-1-MQTT-tp4680744p4681425.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ Plugin: Modify consumer subscription

Hello, I would like to know whether it is possible to modify the destination of a consumer subscription within a broker plugin. Assuming that two producers (A and B) and one consumer (C) are connected to a single broker. Producer A publishes to the destination "Foo", producer B publishes to the

Re: ActiveMQ with Oracle + failover + Stuck Session

Thanks Looks like the solution. Will be testing. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-with-Oracle-failover-Stuck-Session-tp4681362p4681423.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Many "loaded class org.eclipse.jetty.jndi.NamingContext"

Hi, I checked more At least the source on May 18, jetty log is shown. But the source on May 7, the log is not shown. mtakahashi -- View this message in context: http://activemq.2283324.n4.nabble.com/Many-loaded-class-org-eclipse-jetty-jndi-NamingContext-tp4681421p4681422.html Sent from the Ac

Many "loaded class org.eclipse.jetty.jndi.NamingContext"

Hello, I built activeMQ from source and run it. If I change log level ALL, as following, --- log4j.rootLogger=ALL, logfile, console log4j.appender.console.threshold=ALL -- Many jetty related log was shown. If I removed "" in activemq.xml jetty log was not shown. I have also checked ver. 5.9.1 as

Re: Dynamic discovery for client libraries

Noel, thanks for the info about fabric8, will check it out. What regarding the MQTT - do not know as well whether it is feasible within the protocol to pass the clustering info. But I do not limit the scenario to MQTT only, it was only as example of let's say external client. What do I want to ac