Re: ActiveMQ persistent store (KahaDB) for Topics Vs Queues

Hey Tim, So a persistent message sent on a topic will not go to KahaDB store unless there is a durable subscriber ? Correct me if I am wrong Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-persistent-store-KahaDB-for-Topics-Vs-Queues-tp4681494p

overhead of delayed messages? what data structure does it use? would 1M kill it?

What data structure does ActiveMQ use for delayed messages. I think this is exactly what I need, but it could be easy for us to accidentally enqueue 1M delayed messages. and if our throughput falls of in that situation then the total overall system throughput will fail. One idea is to have a who

Re: 1M queues?

… sorry. That previous email accidentally sent. I imagine I could keep everything in ONE queue… which makes things easier. > It's use that at certain times, some items could be throttled into the > millions of items. .. I was going to say this would mean one queue, with a backlog of millions o

Re: 1M queues?

I imagine I could keep everything in ONE queue… which makes things easier. It's use that at certain times, some items could be throttled into the millions of items. On Thu, May 29, 2014 at 12:21 PM, Gaurav Sharma wrote: > Without knowing much about the domain, now that doesn't seem like the >

Re: 1M queues?

Without knowing much about the domain, now that doesn't seem like the best way to attack this problem. If you were hoping to do any sort of secondly or few-secondly moving windows, the rpc/remoteness alone would negate the use of such a system. A remote system for rate throttling is better suited f

1M queues?

How would activemq handle a lot of queues per box? Like 1M … I'm doing this to implement throttling. and since we can get stats on each queue, I can see if we're massively backlogged on one of the queues. AIs each queue its own database? -- Founder/CEO Spinn3r.com Location: *San Francisco, C

Using interceptors and delays to implement throttling.

I have a standard producer/consumer model with N consumers listening on queues. One of the problems we have is that some of our resources are constrained. We don't want to fetch them too often so we throttle them. We're migrating to activemq and need this feature to switch over. I'm thinking ab

broker camel component creating an infinite loop

Hi, I'm trying to intercept a message at the broker level and redirect it to a test queue if a certain header is present, otherwise leave the message to go where it is. I've been following this guide: http://activemq.apache.org/broker-camel-component.html and camel.xml entry looks like this:

Messages dequeue but persistent store never decreases

We are trying to run perf tests and keep hitting this error javax.jms.ResourceAllocationException: Persistent store is Full, 100% of 2147483648. Stopping producer (ID:x-52166-1401201837673-1:1:1:1) to prevent flooding queue://x..x. See http://activemq.apache.org/producer-flow-contro

Re: ActiveMQ message dequeuing hangs

I looked at the thread dump but it does not point to something obvious. Attached are the thread dumps. I am trying to simulate this on a pure vanilla ActiveMQ instance with some random data. On Tue, May 27, 2014 at 5:08 PM, ceposta [via ActiveMQ] < ml-node+s2283324n4681454...@n4.nabble.com> wrot

Re: ActiveMQ persistent store (KahaDB) for Topics Vs Queues

On 05/29/2014 02:30 AM, khandelwalanuj wrote: Hi, ActiveMQ v5.8 Is there any difference in kahaDB store technique for topics and queues. When producer sends a persistent message on a destination, Does kahaDB use different ways to store for topics and queues ? I was seeing some of the ActiveMQ

10% of messages missing

Hi all, I'm facing some problems with activemq. I'm using version 5.6 with the default configuration. I've only one producer and one consumer. Actually it is one application which is first sending messages to queue and then reading them. My activemq is running on a virtual machine placed in the

ActiveMQ MQTT SSL Problem

Hi Im trying to integrate my mosquitto client to activemq mqtt broker with SSL. There is a problem at handshaking and cpiher suites here is my client and server logs; ./mosquitto_sub -h localhost -p 8883 -t "SERVICE_TOPIC" --cafile /etc/mosquitto/ca_certificates/ca.crt -d --tls-version tlsv1 Cli

Re: How to encrypt password in broker-config.xml and ra.xml

Hi, Does any one have suggestions for my above query? regards D -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-encrypt-password-in-broker-config-xml-and-ra-xml-tp4681449p4681497.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.