I'll try it and will let you know the results..Tnx Robbie..
On Fri, Jan 28, 2011 at 4:54 PM, Robbie Gemmell <[email protected]>wrote: > You mention using Qpid 0.9, i.e. trunk, but how up to date are you > with the latest revision? I fixed a couple of severe memory 'leaks' > with the Java broker earlier this week that could certainly be your > problem, so if you aren't fully up to date I'd start with that. > > Robbie > > On 28 January 2011 13:58, mravko <[email protected]> wrote: > > 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&period=1&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 > > > > --------------------------------------------------------------------- > Apache Qpid - AMQP Messaging Implementation > Project: http://qpid.apache.org > Use/Interact: mailto:[email protected] > >
