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
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
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
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