[rabbitmq-discuss] Garbage Collection Problem in Consumer

Tue Feb 2 12:29:04 GMT 2010

Hi ,

Please find the attached code for Consumer.java.

public class SingleConsumer{

 public static void main(String args[]) {

 ConnectionParameters params = new ConnectionParameters();

params.setUsername(janusProperties.getProperty("rabbitmq_userName").trim());

params.setPassword(janusProperties.getProperty("rabbitmq_password").trim());
            params.setVirtualHost("/");
            params.setRequestedHeartbeat(0);
            ConnectionFactory factory = new ConnectionFactory(params);
            com.rabbitmq.client.Connection connRMQ =
factory.newConnection(janusProperties.getProperty("rabbitmq_server_ip").trim(),
Integer.parseInt(janusProperties.getProperty("rabbitmq_server_port").trim()));

            Channel channel = connRMQ.createChannel();

            String exchangeName =
janusProperties.getProperty("rabbitmq_exchangeName").trim();
            String queueName =
janusProperties.getProperty("rabbitmq_queueName").trim();
            String routingKey =
janusProperties.getProperty("rabbitmq_routingKey").trim();

            QueueingConsumer consumer = new QueueingConsumer(channel);
            channel.basicConsume(queueName, true, consumer);
           QueueingConsumer.Delivery delivery;
            while (!runInfinite)
            {
                      try {

                     delivery = consumer.nextDelivery();

                         } catch (InterruptedException ie) {
                    log.debug("Problem in Deliverying the message");
                    continue;
                }

                  /* 1 . Do some operation on the consumed data which will
take 2 -3 sec of time.
                      2. if above operation is success than continue to
receive next data
                      3. if above operation fails than resend the message
back to the queue( Consumer acting as Producer) using channel.basicPublish

                  */
                    channel.basicPublish(exchangeName, routingKey, true,
false, MessageProperties.PERSISTENT_TEXT_PLAIN, bao.toByteArray());

}

}
        }

Memory leakage is because of operating on the data which take times. In that
time the QueueingDelivery objects are created as many as the the messages
sent by the Producer.

Thanks,
Seema
On Tue, Feb 2, 2010 at 5:01 PM, Gustavo Aquino <aquino.gustavo at gmail.com>wrote:

> Seema,
>
> You can't control when your GC will run, if you declare this objects into
> loop and don't are using hash tables or maps to reutilize it, so it will
> be eligible to GC automatically, because your life cycle over in next loop.
>
> Today I have a consumer in Java consuming about 1.000 m/s and never used
> more than 15Mb and this objects never go throw eden memory, if you don't
> forward this objects created inside consumer loop, this objects will be
> automatic eligible for GC but GC don't run immediately you need to wait.
>
> Can you post your consumer code ?
>
>
>
>   On Tue, Feb 2, 2010 at 3:48 AM, Seema Biradar <seemasbiradar at gmail.com>wrote:
>
>>   Hi All,
>>
>> i tried the rabbit MQ with Producer and Consumer Program.
>>
>> in Consumer side i am getting the all the Message, but the following
>> objects
>>
>> com.rabbitmq.client.QueueingConsumer.Delivery
>> com.rabbitmq.client.Envelop
>> com.rabbitmq.client.AMQP.BasicProperties
>>
>> are created for each message and not garbage collected immediately after
>> consuming.
>>
>> *in Producer.java
>> *
>> used basic publish as shown below.
>>
>> channel.basicPublish(exchangeName, routingKey, true, false,
>> MessageProperties.PERSISTENT_TEXT_PLAIN, bao.toByteArray()) ;
>>
>>
>> *Consumer.java
>> *
>> channel.basicConsume(queueName, true, consumer);
>>
>> with no-acknowledgement *true*.
>>
>> Please let me know, how to make the above object eligible for garbage
>> collection immediately after consuming.
>> for Consumer program The Heap Memory allocated is more , as this is
>> performace issue
>>
>>
>> Thanks,
>> Seema
>>
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>
>>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20100202/db1c999e/attachment.htm 