Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of elihusmails@gmail.com
 designates 209.85.134.191 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=message-id:date:from:to:subject:cc:mime-version:content-type
         :content-transfer-encoding:content-disposition;
        b=Vy60G5HR6s8wHpYYsOO9V7I10wgOaNhbcogvKNk/QE7f1kaLD9bVZX8Q4cP6qlneOx
         /34RGFnm4iV/vE2SLJ0k0U54XW3dEtJafUrZt01bRUSNDPBG0+OMnsUKhULbxamHQ8sZ
         E4Z5WY4zTrbP1rKkioXyg2QfGfUygSOdATM6A=
Message-ID: <9f066ee90810091755t103b57e4t996ff730fe41159f@mail.gmail.com>
Date: Thu, 9 Oct 2008 20:55:31 -0400
From: "Mark Webb" <elihusmails@gmail.com>
To: users@activemq.apache.org
Subject: memory leak problem with ActiveMQ 5.1
Cc: elihusmails@gmail.com
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit
Content-Disposition: inline

I have run across a memory leak that I have been able to reproduce.  I
am profiling the sample application in NetBeans and I believe that I
have traced the problem to
org.apache.activemq.openwire.v3.BaseDataStreamMarshaller.tightUnmarshalByteSequence(DataInput,
BooleanStream)

The sample program is a very simple application that sends an object
that I wrote to ActiveMQ every 200ms.  In NetBeans I am using the
"Live Allocated Objects" view and approximately 80% of all objects are
byte[].  If I view the Allocation Call Tree, the first few methods in
the tree are:

BaseDataStreamMarshaller.tightUnmarshalByteSequence(DataInput, BooleanStream)
   org.apache.activemq.util.ByteArrayOutputStream.checkCapacity(int)
       org.apache.activemq.util.ByteArrayOutputStream.<init>
          java.lang.StringCoding$StringEncoder.encode(char[],int,int)

The object that I am sending is a simple bean class and only contains
an int, String and byte[].

I am using the base configuration for ActiveMQ.  All my sample
application does is call sendObject(Serializable) every 200ms.  Here
is the simple JMS library that I wrote:

------------- START --------------------------
public class JmsLib {

    private TopicConnection connection;
    private Session session;
    private Topic destination;
    private MessageProducer producer;
    private MessageConsumer consumer;

    public JmsLib( ActiveMQConnectionFactory connFactory, String dest
) throws JMSException {

        connection = connFactory.createTopicConnection();
        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        destination = session.createTopic( dest );
        producer = session.createProducer( destination );
        consumer = session.createConsumer( destination );
        connection.start();
    }

    public void addMessageListener( MessageListener listener ) throws
JMSException{
        consumer.setMessageListener( listener );
    }

    public void sendObject( Serializable object ) throws JMSException{
        ObjectMessage message = session.createObjectMessage( object );
        producer.send(message);
    }
}
--------------- END --------------------------

Thanks for any help you may have...