Re: Plugins do not get initialized for failover broker

I also have similar requirement where I wrote a java class to monitor my broker and some other stuff. I want to run it with broker (other than plugin way) How should I do it ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Plugins-do-not-get-initialized-for-failover-brok

Any Performance/Latency benchmarks for ActiveMQ's AMQP implementation against OpenWire ?

I do understand that the AMQP implementation in ActiveMQ is fairly new and may not be optimized much but it would still help me a lot if anyone can share their performance and latency benchmarks as against Openwire. Thanks, Bhanu -- View this message in context: http://activemq.2283324.n4.nabb

Re: Plugins do not get initialized for failover broker

Hey, I have gone through https://issues.apache.org/jira/browse/AMQ-4867 So it says if I want to monitor my failover broker I need to start in a separate way(not the plugin way) So Can you tell where I could start this monitoring thing in configuration file ? I mean to say.. where could I use my be

Re: Subscribe to multiple topics

Hi, 1. I can't use wild cards because my topics doesn't follow any specific pattern like topic.A, topic.B. They can be anything. There is another problem with this approach. Say I use a wildcard topic.* to receive from topic.A and topic.B only. But if someone publishes on topic.X I will receive tho

RE: What does DTO stand for?

Thanks. I had no idea what DTO stood for. Now that I do I take it they would be useful if I were to access the broker from my server when it is running as a standalone server. Since I hope to avoid that and run the MQTT broker as an embedded broker from inside my server application (don't know how

RE: What does DTO stand for?

> Thanks to whomever can explain what DTO means and how it differs from the > non-DTO classes. DTO usually refers to "data transfer object" and is a standard [Java|software] design pattern (see http://en.wikipedia.org/wiki/Data_transfer_object). T

Re: What does DTO stand for?

I believe the DTO stuff is meant to hold data values from the XML configuration files. DTO = "data transfer object" On Wed, Nov 20, 2013 at 2:44 PM, Brian Reinhold wrote: > I know its a stupid question but being 100% new to ActiveMQ I see complete > sets of classes that look very similar except

What does DTO stand for?

I know its a stupid question but being 100% new to ActiveMQ I see complete sets of classes that look very similar except one set is suffixed with 'DTO' and another is not. I have been unable to find what the DTO means and how it may affect what I want to do. (I want to use ActiveMQ to embed an MQTT

Re: Small number of messages stuck in full mesh failover

Thanks Gary, I tried policyEntry useCache="false" with ActiveMQ 5.8 and ActiveMQ 5.9, but no success, I still see messages stuck in Queues, I still have to try with 5.10 SNAPSHOT. I will post a update after that -- View this message in context: http://activemq.2283324.n4.nabble.com/Small-numb

Re: maxReconnectAttempts in failover transport

Thanks Tim 2013/11/20 Timothy Creswick : >however the client isn't able to resolve the name that it receives. That makes sense for for me , but client's machine has got these entries in its hosts file It's weird. Maybe I'm not doing the right tests So far, I'm going to disable that feature Rega

Re: Subscribe to multiple topics

Have you tried these: http://activemq.apache.org/composite-destinations.html http://activemq.apache.org/wildcards.html On Wed, Nov 20, 2013 at 2:56 AM, Steven Turner wrote: > Hi, > I have a requirement where I want to *subscribe to multiple activemq topics. > What is the best way to do this?* >

Re: Does AMQP supports ActiveMQ failover options in URL ??

On 11/20/2013 12:25 PM, xbhanu wrote: How does AMQP fare against Openwire in terms of performance and latency ? AMQP and Openwire are protocols. Throughput and latency can only be measured against implementations. So while in theory, aspects of a protocol can impact performance in different w

RE: maxReconnectAttempts in failover transport

> javax.jms.JMSException: java.net.UnknownHostException See my earlier posts on this subject, but the problem is that your broker is sending connection details for the other brokers to your client, however the client isn't able to resolve the name that it receives. For example, if you have two

Re: Does AMQP supports ActiveMQ failover options in URL ??

Thanks Gordon. How does AMQP fare against Openwire in terms of performance and latency ? For ActiveMQ Devs:- Is there an easy migration wiki page for a naive client to migrate from OpenWire/STOPM to AMQP? And lastly, Any ideas when is it slated(or even planned) to have an ActiveMQ specific AMQP

Re: maxReconnectAttempts in failover transport

I could find out that this error is caused by updateClusterClients="true" So, I need to se it to false Thanks 2013/11/20 Jose María Zaragoza : > Hello: > > I'm using AMQ 5.8.0 > > I've defined the next transport failover > > "failover:(tcp://broker1:61616?connectionTimeout=3000,tcp://broke

maxReconnectAttempts in failover transport

Hello: I'm using AMQ 5.8.0 I've defined the next transport failover "failover:(tcp://broker1:61616?connectionTimeout=3000,tcp://broker2:61616?connectionTimeout=3000)?timeout=5000&startupMaxReconnectAttempts=1&maxReconnectAttempts=1&randomize=false&priorityBackup=false" I start a Consumer, conn

Subscribe to multiple topics

Hi, I have a requirement where I want to *subscribe to multiple activemq topics. What is the best way to do this?* I have tried using multiple DMLC but I get following error: org.springframework.jms.listener.DefaultMessageListenerContainer#refreshConnectionUntilSuccessful 875 WARN] - Could not ref