how much memory does the server have?

- yup, im sure the memory of the servers are fine, i had attached the node1 & node2 "TOP" details in the zip

are you acking all messgaes?

- yeah, actually i want to test the reliability of the hornetq server before deploy to production, everytime i will produce messages (e.g. 100k), and consume them all.

are you closing JMS resources properly?

- im using core api, not using the jms

are there any warnings in the logs?

- i will resimulate the issue and show you the OOM log

hi andy,

I meant how much memory are you actually starting the server with and is it enough, maybe you just need to up it

- i used used the default min512 max1024, i also tried min256 max512

ok, make sure you are closing any resources

- yup, in my code, after i finish the produce or consume, i will close the clientsession, clientsession factory

Yes but check for any other warning previous the OOM.

- i will provide you the warning soon cause now i not in office

If you do recreate it, can you provide a simple test, i.e. not with all your code, so we can recreate it?

- actually i already provided the full code in the attachement, you can try it out, or you want me to write the simple code to test produce and consume messages?

hi clebert,

You probably have a dead subscription (or a queue where you're not consuming messages).

-actually i always only used 1 queue, and then i also use the QueueQuery method to check is there message in the queue including the DLQ and ExpiryQueue

hi andy, as per requested, i had upload the hornet-attach2.zip which have the hornetq log showed the OOM

i also provide a simple test class and try produce 1millions records and consume them concurrently, unfortuntately consume failed due to OOM,

fyi, im using paging which should be work fine right?