Return-Path: 
 <users-return-3704-apmail-qpid-users-archive=qpid.apache.org@qpid.apache.org>
Delivered-To: apmail-qpid-users-archive@www.apache.org
Received: (qmail 21275 invoked from network); 28 Jan 2011 13:58:42 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3)
  by minotaur.apache.org with SMTP; 28 Jan 2011 13:58:42 -0000
Received: (qmail 51488 invoked by uid 500); 28 Jan 2011 13:58:42 -0000
Delivered-To: apmail-qpid-users-archive@qpid.apache.org
Received: (qmail 50503 invoked by uid 500); 28 Jan 2011 13:58:40 -0000
Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@qpid.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@qpid.apache.org>
List-Post: <mailto:users@qpid.apache.org>
List-Id: <users.qpid.apache.org>
Reply-To: users@qpid.apache.org
Delivered-To: mailing list users@qpid.apache.org
Received: (qmail 50495 invoked by uid 99); 28 Jan 2011 13:58:39 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 28 Jan 2011 13:58:39 +0000
X-ASF-Spam-Status: No, hits=1.5 required=5.0
	tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of haustor@gmail.com designates
 209.85.218.42 as permitted sender)
Received: from [209.85.218.42] (HELO mail-yi0-f42.google.com) (209.85.218.42)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 28 Jan 2011 13:58:31 +0000
Received: by yia28 with SMTP id 28so1636937yia.15
        for <users@qpid.apache.org>; Fri, 28 Jan 2011 05:58:10 -0800 (PST)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=gamma;
        h=domainkey-signature:mime-version:date:message-id:subject:from:to
         :content-type;
        bh=DqxJ2lKasMQL8XmJ9hCeGjoln3U1qlEvZ03SG4+sXM0=;
        b=uefSpUgS2Y8BVQ/88NzLzz+7W9mMqcsnoSO50IBpGWhyhuOggcQgRZm+4eDBelD3Qt
         88pI82uFG8OVm9AtdDz9mWmRj0Hg/+savM++S9bvxg97niR/8AufwMlXSmjaGe72RByz
         IRbr4iYSPu3hpYzLK73L/W2ByDN9dFTwaNOx0=
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:date:message-id:subject:from:to:content-type;
        b=RzXMJlaaioDjgIZeDkcWRr1TKKlyQYOZLgMYAgjqMT1GeWe5gHmX2QX9+Suu2spsJC
         Ax6IyNfwLKy1EZI9PpIbbg5MdaO+f38pxCPMchWpJZNXffXMns5LCLNag7wkecsTrNu9
         tk/jgbpsQbFF/pnYvQR6E5looaZNqMqrEE9Gw=
MIME-Version: 1.0
Received: by 10.150.176.2 with SMTP id y2mr4230420ybe.368.1296223089936; Fri,
 28 Jan 2011 05:58:09 -0800 (PST)
Received: by 10.150.12.1 with HTTP; Fri, 28 Jan 2011 05:58:09 -0800 (PST)
Date: Fri, 28 Jan 2011 14:58:09 +0100
Message-ID: <AANLkTi=R1XUi7u201Ysqb5wA9649MDpMhAmAcZewfPVc@mail.gmail.com>
Subject: qpid memory consumption
From: mravko <haustor@gmail.com>
To: users@qpid.apache.org
Content-Type: multipart/alternative; boundary=000e0cd73438d34b95049ae87412
X-Virus-Checked: Checked by ClamAV on apache.org

--000e0cd73438d34b95049ae87412
Content-Type: text/plain; charset=ISO-8859-1

Hi,
I made simple consumer-producer example in spring with camel and qpid and
the thing is that I have constant increase in memory  usage on broker until
heap space exception..
Consumer is receiving messages and prints them in console..I checked broker
qpid jmx console, there is one temp queue but messages are regularly
consumed from it (message count drops to 0)..Maybe I am missing something..I
am using java qpid 0.9, camel-amqp-1.6.0.0-fuse and standard qpid libs..

Configuration from virtualhosts.xml, I made virtualhost for my needs and
this is slice of code where I define my topic
--------------------------------------------------------------------------
<exchanges>
                <exchange>
                    <type>direct</type>
                    <name>test.direct</name>
                    <durable>true</durable>
                </exchange>
                <exchange>
                    <type>topic</type>
                    <name>test.topic</name>
                </exchange>
                <exchange>
                    <type>topic</type>
                    <name>topic.newsoutput</name>
                </exchange>

   </exchanges>
--------------------------------------------------------------------------

And here is my spring context code
--------------------------------------------------------------------------
Producer

<!-- Camel route from timer, which returns message that is passed via broker
to consumer-->
    <camel:camelContext id="camelInputContext">
    <camel:route id="timerRoute">
            <camel:from

uri="timer://newsTimer?fixedRate=true&amp;period=1&amp;delay=1" />
                <camel:bean ref="messageProducer"/>
            <camel:to uri="amqp:topic.newsoutput" />
        </camel:route>
    </camel:camelContext>

    <!-- this bean just returns string-->
    <bean id="messageProducer" class="qpid.MessageProducer"></bean>


    <bean id="amqpConnectionFactory"
class="org.apache.qpid.client.AMQConnectionFactory">
        <constructor-arg
            value="amqp://guest:guest@clientid/matcher?brokerlist='tcp://localhost:5672'"
/>
    </bean>


    <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
        <constructor-arg ref="amqpConnectionFactory"></constructor-arg>
    </bean>

    ---------------------------------------------------------------------
Consumer

    <camel:camelContext id="camelInputContext">
        <camel:route id="inputRoute">
            <camel:from uri="amqp:topic.newsoutput" />
            <camel:process ref="messageProcessor" />
    </camel:route>
    </camel:camelContext>


    <!-- MessageProcessor simply prints out message-->
    <bean id="messageProcessor" class="qpid.MessageProcessor" />

    <bean id="amqpConnectionFactory"
class="org.apache.qpid.client.AMQConnectionFactory">
        <constructor-arg
            value="amqp://guest:guest@clientid/matcher?brokerlist='tcp://localhost:5672'"
/>
    </bean>


    <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
        <constructor-arg ref="amqpConnectionFactory"></constructor-arg>
    </bean>

------------------------------------------------------------------------

Please help..
Marko

--000e0cd73438d34b95049ae87412--