Hi Norman,
Did you mention stg like this?
from("jms:test.MyQueue?transacted=true,transactionManager=JmsTransactionManager")
.to(ftp://[email protected]:21/?password=test);
I tried this route (without using ProducerTemplate & PollingConsumer) but I
couldn't receive any message when I stop & start FTP server.
PS. I can't use lazyCreateTransactionManager because I'm using camel 1.6.1.
This is why I used transactionManager=JmsTransactionManager option.
Best regards
Ilker
Norman Maurer-3 wrote:
>
> Why not use transactions then? Just mark the route transacted, this should
> work.
>
> Bye
> Norman
>
> 2010/5/4, olamalam <[email protected]>:
>>
>> Hi to all,
>>
>> I'm trying to write a route (with camel 1.6.1) that listens to a JMS
>> queue
>> and sends file to a FTP server. Simply:
>> from("jms:test.MyQueue").to("ftp://[email protected]:21/?password=test";);
>>
>> But I have to handle the case that the FTP server is down. In order not
>> to
>> loose any message I have to keep the messages when the server is down and
>> resend to the server when it is started again. To implement this case
>> I've
>> used ProducerTemplate & PollingConsumer instade of the route above. Now
>> my
>> code looks like this:
>>
>> public void configure() {
>> from("file://e:/temp/data?noop=true").to("jms:test.MyQueue");
>> final ProducerTemplate<Exchange> producerTemplate =
>> getContext().createProducerTemplate();
>>
>> producerTemplate.send("jms:test.MyQueue", processor);// processor updates
>> the file name.
>> PollingConsumer<Exchange> consumer = null;
>> try{
>> final Endpoint<Exchange> endpoint =
>> getContext().getEndpoint("ftp://[email protected]:21/?password=test";);
>> consumer = endpoint.createPollingConsumer();
>>
>> consumer.start();
>> while(true){
>> final Exchange receive = consumer.receive();
>> }
>> }catch(final Exception e1){
>> LOG.error(e1.getMessage());
>> }finally{
>> try{
>> consumer.stop();
>> }catch(final Exception e){
>> LOG.error(e.getMessage());
>> }
>> }}
>>
>> When I stop the ftp server and send messages to queue I still loose these
>> messages after starting the ftp server. Does anyone knows what I'm
>> missing
>> here?
>>
>> Thanks in advance
>> Ilker
>> --
>> View this message in context:
>> http://old.nabble.com/ProducerTemplate---PollingConsumer-problem-tp28445093p28445093.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>>
>
>
--
View this message in context:
http://old.nabble.com/ProducerTemplate---PollingConsumer-problem-tp28445093p28445795.html
Sent from the Camel - Users mailing list archive at Nabble.com.
