ProducerTemplate & PollingConsumer problem

[olamalam]

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://t...@127.0.0.1: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://t...@127.0.0.1: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.