Hi, I'm currently using ActiveMQ ver5.0 with persistence turned on, and running 1 broker, 1 producer, and 1 consumer. I'm using a queue to send and receive non-transactional ObjectMessages. The objects in the messages are several megs, hence, I have setUseCompression(true).
The problem I'm encountering is that after sending and receiving several messages, I can see via jprofiler that there is a byte[] object whose memory usage keeps increasing. In observing the heap from the profiler, it seems that the size of the LinkedList variable, "pagedInMessages" in org.apache.activemq.broker.region.Queue contains several elements, each several KB in size. However, it does not seem that the number of elements in the LinkedList is ever reduced, at least not before I've reached the max heap allowed for the jvm (which is 1024M). After looking at the ActiveMQ 5.1 API snapshot, it seems that the elements in pagedInMessaged are not gc'ed until the size of pagedInMessages >= maximumPagedInMessages. Is this correct? In this case, is there any way to reduce the number of message reference/messages paged in? If it helps any, I've tested with: prefetch limit = 1 CopyMessageOnSend = false OptimizeAcknowledge = false -- View this message in context: http://www.nabble.com/ActiveMQ-ver5.0-number-of-paged-in-messages-tp14860957s2354p14860957.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
