Thank you for your help
Claus Ibsen-2 wrote:
>
> On Tue, Nov 24, 2009 at 6:17 PM, titexe wrote:
>>
>> Thank you for your reply
>>
>> my need is simple, I want to transfer messages from the queue A to queue
>> B,
>> each 1 hour.
>>
>> I think the examples that are present in this page is not us
Thank you for your help,
Claus Ibsen-2 wrote:
>
> On Tue, Nov 24, 2009 at 6:17 PM, titexe wrote:
>>
>> Thank you for your reply
>>
>> my need is simple, I want to transfer messages from the queue A to queue
>> B,
>> each 1 hour.
>>
>> I think the examples that are present in this page is not
On Tue, Nov 24, 2009 at 6:17 PM, titexe wrote:
>
> Thank you for your reply
>
> my need is simple, I want to transfer messages from the queue A to queue B,
> each 1 hour.
>
> I think the examples that are present in this page is not used to me.
>
> de you have ideas that could help me ?
>
Well As
Thank you for your reply
my need is simple, I want to transfer messages from the queue A to queue B,
each 1 hour.
I think the examples that are present in this page is not used to me.
de you have ideas that could help me ?
thank you again
titexe
Ashwin Karpe wrote:
>
> Hi,
>
> You could d
Hi,
You could do the following
from("timer://foo?period=360").
process (new Processor(Exchange exchange) {
exchange.getOut().setBody("My FooBar Message");
}).
to(activemq:MyQueue);
from
Hi,
You could do the following
from("timer://foo?period=360").
process (new Processor(Exchange exchange) {
exchange.getOut().setBody("My FooBar Message");
}).
to(activemq:MyQueue);
from
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 wrote:
> new Thread(new Runnable() {
> @Override public void run() {
>
new Thread(new Runnable() {
@Override public void run() {
try {
PollingConsumer consumer =
getContext().getEndpoint("activemq:queue1").createPollingConsumer();
Producer pr