Re: Wrapper?

2015-02-28 Thread Marc Schöchlin
Hi, Am 26.02.2015 um 19:16 schrieb Kevin Burton: > Great! > > Is there a link to this? Where is it? I have my own project that makes > ActiveMQ into a more proper Debian package. I was thinking of trying to > merge it into ActiveMQ and was researching this. > It is part of activemq - see bin/ac

Re: ActiveMQ refusing to send messages to my clients.

2015-02-28 Thread Tim Robbins
Hi Kevin, Knowing how the clients are consuming messages could help, i.e. whether it’s transactional or not, whether MessageConsumers are being reused/pooled, etc. As a long shot, I’d try lowering the prefetch limit client side. I’ve had to do this occasionally to work around inefficient Camel

ActiveMQ refusing to send messages to my clients.

2015-02-28 Thread Kevin Burton
I’m having a weird situation where ActiveMQ is refusing to send messages to my consumers. I have 4 main queues that my consumers receive messages on. I have plenty of them. They have plenty of CPU, network, etc. I looked at their stack traces and they’re ALL waiting to receive messages. ActiveM

Re: Durable subscription not receiving messages

2015-02-28 Thread Tim Bain
Are messages being sent to the topic at the time the consumer reconnects, or is it just consuming a backlog of already-sent messages? On Feb 28, 2015 3:47 AM, "Peter Hicks" wrote: > Hello > > I'm using ActiveMQ 5.10.1 running under OpenJDK 1.13.6. I'm encountering > a problem where I reconnect t

Re: Several hundred messages occupies almost 30G storage

2015-02-28 Thread Tim Bain
KahaDB can only delete a data file when every message in it can be deleted. If a single message is still needed, the whole file must be kept, and it doesn't perform any sort of compaction. And if the last message in a file that must be kept (because of some other message) has an ack in the next f

Re: Several hundred messages occupies almost 30G storage

2015-02-28 Thread Rural Hunter
One more question: will the same thing happen if I switch to leveldb? 2015-02-28 22:53 GMT+08:00 Rural Hunter : > I'm sorry I made a mistake. My storage is kahadb. We switched from leveldb > to kahadb a while ago and I forgot that. > Thanks for the links. Now understand what happened! > > 2015-02

Re: Several hundred messages occupies almost 30G storage

2015-02-28 Thread Rural Hunter
I'm sorry I made a mistake. My storage is kahadb. We switched from leveldb to kahadb a while ago and I forgot that. Thanks for the links. Now understand what happened! 2015-02-28 19:03 GMT+08:00 Tim Robbins : > Hi, > > Two suggestions for you: > > 1. Try decreasing the logSize parameter for Level

Re: Several hundred messages occupies almost 30G storage

2015-02-28 Thread Tim Robbins
Hi, Two suggestions for you: 1. Try decreasing the logSize parameter for LevelDB. You’ve have a greater number of smaller log files, and a greater chance of each log file being garbage-collected. 2. With KahaDB, it’s possible to configure multiple KahaDB stores, and to put your dead-letter typ

Durable subscription not receiving messages

2015-02-28 Thread Peter Hicks
Hello I'm using ActiveMQ 5.10.1 running under OpenJDK 1.13.6. I'm encountering a problem where I reconnect to a topic using a subscriptionName, but no messages are dequeued. Looking at the conversation in Wireshark: * Client sends a CONNECT frame with a client-id * Server sends a CONNEC

Several hundred messages occupies almost 30G storage

2015-02-28 Thread Rural Hunter
Hi, Activemq version 5.10.2, storage: leveldb. I have a queue which serves similiar function as dead letter queue. My application process messages from another queue and if the processing fails, it put the message into this queue. The messages are persistent and average several KBs in size. My a