Re: Camel : slow processing of messages

2009-11-20 Thread Dmitry Ulanov
May be it's a bug. If you stop camel via JMX, after restart queue subscriptions aren't restored. Clause, do you know anything about it? On Fri, Nov 20, 2009 at 6:31 PM, titexe tit...@yahoo.fr wrote: the problem, when i look of the attributes of this queue, i found ConsumerCount 0 and the

Re: Camel : schedule the move of messages

2009-11-20 Thread Dmitry Ulanov
new Thread(new Runnable() { @Override public void run() { try { PollingConsumer consumer = getContext().getEndpoint(activemq:queue1).createPollingConsumer(); Producer

Re: Camel : schedule the move of messages

2009-11-20 Thread Dmitry Ulanov
Sorry for my example, just see Timer based polling consumer paragraph on http://camel.apache.org/polling-consumer.html. On Fri, Nov 20, 2009 at 6:40 PM, Dmitry Ulanov dula...@gmail.com wrote: new Thread(new Runnable() { @Override public void run

Re: Camel : slow processing of messages

2009-11-19 Thread Dmitry Ulanov
Do you just write to db or read/write? May be the problem would be solved by creating indexes for db. On Thu, Nov 19, 2009 at 12:15 PM, Claus Ibsen claus.ib...@gmail.com wrote: On Thu, Nov 19, 2009 at 9:58 AM, titexe tit...@yahoo.fr wrote: Hello; I have a route camel that makes the

Re: Camel iBatis : management of real-time recording of a database?

2009-10-26 Thread Dmitry Ulanov
iBatis like any JDBC will work by timer (quartz library). For example, you can set it to fire every second: from(quartz://CurrencyRates/secondAttempt/1,2,3,4,5,6,7,8,9,10,...,59/*/*/*/*/$) .to(ibatis:statement?statementType=QueryForList)... On Mon, Oct 26, 2009 at 4:46 PM, titexe tit...@yahoo.fr

Re: Camel iBatis : management of real-time recording of a database?

2009-10-23 Thread Dmitry Ulanov
Camel iBatis componet is just very simple wrapper around Apache iBatis library which very close to JDBC by performance and time assumption. Is JDBC can manage your real time? I don't know exactly. On Fri, Oct 23, 2009 at 9:41 PM, titexe tit...@yahoo.fr wrote: Hello, We would like to copy in

Re: Camel assertion error

2009-10-21 Thread Dmitry Ulanov
In Java Objects are comared via equals() method, not toString(). I usually use Jakarta Lang libarary to automate it. For example: import java.io.Serializable; import org.apache.commons.lang.builder.EqualsBuilder; import org.apache.commons.lang.builder.HashCodeBuilder; import

Re: How to aggregate all messages into a single message?

2009-10-15 Thread Dmitry Ulanov
Try to use this.from(FROM_FOLDER).split(new LdapEntitySplitExpression(), new LdapAggregationStrategy()).process(new LdapModifyProcessor()).end().to(TO_FOLDER); On Thu, Oct 15, 2009 at 5:01 PM, kodcanavari kodcanav...@gmail.com wrote: Hi, I want to use an aggregator in order to aggregate all