load test - ProtocolEncoderException: java.lang.OutOfMemoryError: Java heap space

[Bhupendra Bhardwaj <bh...@gmail.com>]

Hi Mina dev team,

I am working on Apache Qpid Project and we are using mina v1.0.0.
I am doing some load testing for Java Qpid and in a test, where the messages
of size 100KB are being sent, I get the following error after producer sends
around 29,000 messages. The test is being run with -Xmx3072m and sessions
are non-transacted and with no_ack.

I am not sure, if I am providing enough information about the scenario, so
please do ask if there is something anyone needs to know, to answer this
problem.
I would like to know, that if this is a limitation of IOSession and there
should be a pause before sending more messages or there is something that
needs to be done in our application so that the cache is flushed properly.


The error stack is following-
org.apache.mina.filter.codec.ProtocolEncoderException:
java.lang.OutOfMemoryError: Java heap space
        at org.apache.mina.filter.codec.ProtocolCodecFilter.filterWrite(
ProtocolCodecFilter.java:241)
        at
org.apache.mina.common.support.AbstractIoFilterChain.callPreviousFilterWrite
(AbstractIoFilterChain.java:573)
        at org.apache.mina.common.support.AbstractIoFilterChain.access$1200(
AbstractIoFilterChain.java:52)
        at
org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.filterWrite
(AbstractIoFilterChain.java:789)
        at
org.apache.mina.common.support.AbstractIoFilterChain$2.filterWrite(
AbstractIoFilterChain.java:213)
        at
org.apache.mina.common.support.AbstractIoFilterChain.callPreviousFilterWrite
(AbstractIoFilterChain.java:573)
        at
org.apache.mina.common.support.AbstractIoFilterChain.fireFilterWrite(
AbstractIoFilterChain.java:564)
        at org.apache.mina.transport.socket.nio.SocketSessionImpl.write0(
SocketSessionImpl.java:186)
        at org.apache.mina.common.support.BaseIoSession.write(
BaseIoSession.java:146)
        at org.apache.mina.common.support.BaseIoSession.write(
BaseIoSession.java:132)
        at org.apache.qpid.client.protocol.AMQProtocolSession.writeFrame(
AMQProtocolSession.java:282)
        at org.apache.qpid.client.protocol.AMQProtocolHandler.writeFrame(
AMQProtocolHandler.java:422)
        at org.apache.qpid.client.BasicMessageProducer.sendImpl(
BasicMessageProducer.java:508)
        at org.apache.qpid.client.BasicMessageProducer.sendImpl(
BasicMessageProducer.java:420)
        at org.apache.qpid.client.BasicMessageProducer.send(
BasicMessageProducer.java:297)

Thanks and regards,
Bhupendra
Project: Qpid