James.Strachan wrote:
>
> 2008/5/9 Krystian Szczesny <[EMAIL PROTECTED]>:
>>
>>
>>
>> James.Strachan wrote:
>>>
>>> 2008/5/9 Krystian Szczesny <[EMAIL PROTECTED]>:
>>>>
>>>> Hi,
>>>>
>>>>
>>>> Before, when delaying single messages I've used for example
>>>> delayer(3000)
>>>> and it worked flawlessly.
>>>> Now I need to delay a sequence of messages, so when I send 5 messages,
>>>> the
>>>> first should be delayed by 3000, second by 6000 etc...
>>>>
>>>> Is there any way I could do that with Camel?
>>>
>>> You just need to use an expression for the time that the message is to
>>> be sent at. So you could do something like...
>>>
>>> from("activemq:foo").delay().method("someBean",
>>> "sendAtTime").to("activemq:bar");
>>>
>>> then the bean would look like this...
>>>
>>> public class SomeBean {
>>> public long sendAtTime(@Header("MyDelayHeader") long delay) {
>>> if (delay <= 0) delay = 3000;
>>> return System.currentTimeMillis() + delay;
>>> }
>>> }
>>>
>>> which would look for the MyDelayHeader on the message and use that as
>>> the
>>> delay.
>>>
>>>
>>> --
>>> James
>>> -------
>>> http://macstrac.blogspot.com/
>>>
>>> Open Source Integration
>>> http://open.iona.com
>>>
>>>
>> Hi James,
>>
>> thanks for fast answer.
>> One more thing if you could...
>> I am using spring to configure the whole thing:
>>
>> <camelContext id="camel"
>> xmlns="http://activemq.apache.org/camel/schema/spring";>
>> <route>
>> <from uri="activemq:queue:Input" />
>> <delayer>
>> <simple>header.JMSTimestamp</simple>
>> <to uri="activemq:queue:Delayed" />
>> <delay>3000</delay>
>> </delayer>
>> </route>
>> </camelContext>
>>
>> How can I add "method("someBean","sendAtTime")" to this configuration?
>
> <delayer>
> <methodCall bean="something" method="sendAtTime"/>
> ...
> </delayer>
>
> For more details, configure your IDE to use the XSD...
> http://activemq.apache.org/camel/schema/spring/camel-spring-1.3.0.xsd
>
> then you'll get smart completion
>
> --
> James
> -------
> http://macstrac.blogspot.com/
>
> Open Source Integration
> http://open.iona.com
>
>
Thx James,
I've configured Eclipse to use the xsd file, but it does not support smart
completion i guess, it shows everything there is. But never mind that.
I've tried couple of scenarios [delay method returns
System.currentTimeMillis() + 5000]:
FIRST
<camel:camelContext id="camel">
<camel:route>
<camel:from uri="activemq:queue:Delayed" />
<camel:delayer>
<camel:methodCall bean="delayerBean"
method="delay"/>
<camel:to uri="activemq:queue:Output" />
</camel:delayer>
</camel:route>
</camel:camelContext>
Message is delivered to consumer of Output queue before the delay method is
being called.
SECOND:
<camel:camelContext id="camel">
<camel:route>
<camel:from uri="activemq:queue:Delayed" />
<camel:delayer>
<camel:methodCall bean="delayerBean"
method="delay"/>
</camel:delayer>
<camel:to uri="activemq:queue:Output" />
</camel:route>
</camel:camelContext>
Result: same as above - message is consumed before the delay method is
called.
Then I've tried with a class:
public class CamelRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("activemq:queue:Delayed").delayer().method("delayerBean",
"delay").to("activemq:queue:Output");
}
}
and still same result. Message is sent to Output without any delay :/
What am I doing wrong?
--
View this message in context:
http://www.nabble.com/Delay-messages-with-camel-sequentially-tp17144701s22882p17186666.html
Sent from the Camel - Users mailing list archive at Nabble.com.
