Hi Rob,
Thanks for answering my question.
Yes, I am running producer, consumers and broker in the same JVM.
1 consumer for each queue. I'm trying to set the minimumMessageSize
on destinations (to 2048 bytes) as your suggestion, but the OOM error still
occurs.
It seem to me that the broker does
Looks you are running producers/consumers/broker all in the same JVM
using vm:// transport?
As messages won't be serialized going across the vm:// transport -
ActiveMQ will not be able to calculate how much memory each message
takes and apply floe control or offline the messages accordingly.
Hi,
I try to do a performance test of my application. I submit a huge number of
messages
to my application that consist of several message queues and measure a
system throughput.
I use difference size of messages 10 bytes, 100 bytes and 1 Kbytes in this
test.
The problem is that when I run 1 Kb
