Message Priority - consuming

2015-09-01 Thread spamtrap
Is it possible for a consumer to only consume messages above a certain priority, rather than just get them in priority order? Is so how can this be done? I am using ActiveMQ-CPP - latest version.

Re: bridge to Unknown stopped

2015-09-01 Thread Tim Bain
Happy to help, and I'm glad that let you get it working. On Sep 1, 2015 10:26 PM, "wang" wrote: > Hi Tim > Thank you so much. > With the following configuration, it works very well. > > on server 10.80.1.1, add the networkConnectors as the following: > > > > > on se

Re: bridge to Unknown stopped

2015-09-01 Thread wang
Hi Tim Thank you so much. With the following configuration, it works very well. on server 10.80.1.1, add the networkConnectors as the following: uri="static:(tcp://10.80.1.2:61616,tcp://10.80.1.3:61616)"/> on server 10.80.1.2, add the networkConnectors as the follo

Re: What is the correct way to throttle ActiveMQ producers who send persistent messages in batches to a queue?

2015-09-01 Thread jamesTheCruncher
Hi Tim, Thank you very much for the detailed explanation. I agree it is not as such bad to see "Producer stopped" message immediately after "Producer throttled". I merely registered the observations from my test which had no ProducerWindowSize configured. Now that my doubts are cleared, let me tr

Re: bridge to Unknown stopped

2015-09-01 Thread Tim Bain
In that case, you'll want each broker connected simultaneously to both the other two brokers (but not to themselves!), using the static transport instead of masterslave (which is really just syntactic sugar for failover, resulting in a connection to only one of the N underlying URIs). The easiest

Re: bridge to Unknown stopped

2015-09-01 Thread wang
Hi Tim Thanks for you quick reply. What I am trying is to look for a network of brokers (where all brokers are active and forward messages to each other to reach consumers connected to the other brokers, and where messages may be delivered out of order compared to when they were sent). But I d

Re: bridge to Unknown stopped

2015-09-01 Thread Tim Bain
Are you trying to have a master/slave cluster (where only one broker is active and the others are backups, and where message ordering is consistent), or are you looking for a network of brokers (where all brokers are active and forward messages to each other to reach consumers connected to the othe

Re: What is the correct way to throttle ActiveMQ producers who send persistent messages in batches to a queue?

2015-09-01 Thread Tim Bain
James, There are two independent concepts here: 1. what limit gets evaluated to determine whether the producer should stop sending messages 2. which producers should be stopped in response Without ProducerWindowSize, the limits are based on the destination and the entire store (plus other limits

Encrypting password with different key not working

2015-09-01 Thread Awad Shalak
Hi All, I followed the instruction under http://activemq.apache.org/encrypted-passwords.html and it worked perfectly using Apache 5.11.0 just i made a modification to use org.jasypt.spring.properties.EncryptablePropertyPlaceholderConfigurer instead of org.jasypt.spring31.properties.EncryptableProp

Re: bridge to Unknown stopped

2015-09-01 Thread wang
Hi Tim Thanks for you answer. I m trying to accomplish here is because I want to put the three brokers behind a load balancer. So if one broker down, the others could server well. I read from here http://activemq.apache.org/networks-of-brokers.html on that page it said as the following about

Re: bridge to Unknown stopped

2015-09-01 Thread Tim Bain
Why have you configured 10.80.1.1 to connect to itself, and why are 2 and 3 default configurations? More generally, what are you trying to accomplish here? I assume you've read the content at http://activemq.apache.org/masterslave.html, but if not, you need to. On Sep 1, 2015 3:25 AM, "wang" wro

bridge to Unknown stopped

2015-09-01 Thread wang
Hi guys I am Wang and I facing problem when i configured MQTT master-slave using activeMQ 5.12 I have three servers: 10.80.1.1, 10.80.1.2, 10.80.1.3 I deployed default activeMQ instance onto 10.80.1.2, 10.80.1.3. And I added the following networkConnectors to server 10.80.1.1 :