activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mark Webb" <>
Subject memory leak problem with ActiveMQ 5.1
Date Fri, 10 Oct 2008 00:55:31 GMT
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

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)

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 );

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

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

Thanks for any help you may have...

View raw message