memory all used by large consumer transaction

2011-03-23 Thread mar...@attivio.com
Hello, I have an application with a limited memory size. I run with persistence on. There are times when a long running consumer transaction will cause all memory to be consumed in the broker. This eventually leads to Producer blockage (or error -- I've sometimes configured it that way). Since

Re: Inspecting queue depth with ActiveMQ API vs JMX

2011-03-24 Thread mar...@attivio.com
To be honest I've had a tough time doing this with the API. Our goals may be a bit different from yours, we are trying to determine how many messages are on the queue that have not been picked up by a consumer. One of the issues is dealing with prefetch sizes for different consumers and taking th

do open transactions consume memory?

2011-03-28 Thread mar...@attivio.com
Hi, I have an application with a limited memory size. I run with persistence on. There are times when a long running consumer transaction will cause all memory to be consumed in the broker. This eventually leads to Producer blockage (or error -- I've sometimes configured it that way). Since th

Re: Fail in the middle of proccess

2011-03-28 Thread mar...@attivio.com
Not sure exactly what you are asking for, but here is an attempt at answering. Yes. You should should use a transacted session. So, assuming you already have a connection: Session session = connection.createSession(true, 0); Destination queue = session.createQueue("some-queue-name"); Mes