camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Norman Maurer <nor...@apache.org>
Subject Re: ProducerTemplate & PollingConsumer problem
Date Tue, 04 May 2010 10:29:49 GMT
Why not use transactions then? Just mark the route transacted, this should work.

Bye
Norman

2010/5/4, olamalam <ilker.cikrikcili@aspone.co.uk>:
>
> 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://test@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://test@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.
>
>

Mime
View raw message