Hi Claus,
It seems that the problem is the "VodIncomingProcessor" bean, which is
a @RecipientList. Because when I remove it from the route, everything
works fine (using exchange.getIn().setHeader() in the trailerHandler).
A simplified version of the VodIncomingProcessor looks like:
public class VodIncomingProcessor {
private final static Log log =
LogFactory.getLog(VodIncomingProcessor.class);
@RecipientList
public List<String> next(File file) throws IOException {
List<String> recipients = new ArrayList<String>();
log.info("Invoked on file "+file.getCanonicalPath());
if(file.getName().endsWith(".mpg")){
recipients.add("bean:trailerHandler");
}else if(file.getName().endsWith(".pgp")){
recipients.add("bean:pgpHandler");
}else if(file.getName().endsWith(".ts")){
recipients.add("bean:movieHandler");
}
return recipients;
}
}
I guess that the VodIncomingProcessor needs to somehow forward the
File's inputstream to the next step in the route, but i'm not sure how.
Thanks,
Farhad
Begin forwarded message:
Date: August 26, 2009 7:12:26 AM GMT+02:00
Subject: Re: renaming a file in a bean
Source: Nabble - Camel - Users
Author: Claus Ibsen-2
Hi
You want to replace the existing header so use IN
exchange.getOut().setHeader(Exchange.FILE_NAME, rename(fileName));
Should be:
exchange.getIn().setHeader(Exchange.FILE_NAME, rename(fileName));
On Wed, Aug 26, 2009 at 2:02 PM, Farhad Dehghani<m...@...> wrote:
> Hi,
> Please consider the route definition below:
> --------
> <camel:camelContext id="vod_workflow">
> <camel:package>com.nordija.itv.vod.workflow</camel:package>
> <camel:route>
> <camel:from uri="file:///tmp/vodwof?recursive=true" />
> <camel:to uri="file:///tmp/vodIncoming?tempPrefix=.inprogress_
" />
> <camel:to uri="bean:vodIncomingProcessor"/>
> <camel:to uri="direct:route_1"/>
> </camel:route>
> <camel:route>
> <camel:from uri="direct:route_1"/>
> <camel:to uri="bean:trailerHandler"/>
> <camel:to uri="file:///tmp/trailer?tempPrefix=.inprogress_"/>
> <camel:to uri="direct:end"/>
> </camel:route>
> ....
> </camel:camelContext>
> <bean name="trailerHandler"
> class="com.nordija.itv.vod.workflow.TarilerHandlerImpl" />
> ---------
> The vodIncomingProcessor is a @RecipientList annotated bean that
decides if
> the file in question should be handled by the "trailerHandler" or
something
> else.
> The trailerHandler needs among other things to rename the
resulting file.
> The following code is a very simplified version of the bean:
>
> @Service(value="trailerHandler")
> public class TarilerHandlerImpl implements TrailerHandler {
> public void handleTrailer(Exchange exchange) {
> if(exchange != null){
> String fileName =
> (String)exchange.getIn().getHeader(Exchange.FILE_NAME);
> if(fileName != null){
>
> exchange.getOut().setHeader(Exchange.FILE_NAME, rename(fileName));
> }
> }
> }
> }
>
> The "rename(String filename)" method renames the file and it's
> implementation is not relevant here. For test, it just prefix the
filename
> with "trailer_".
> When I run the application, the following exception is thrown, and
the
> trailerHandler gets called again and again.
>
> I appreciate any help,
> -Farhad Dehghani
>
> 13:02:20,913 INFO [STDOUT] 13:02:20,911 ERROR
[GenericFileOnCompletion]
> Cannot store file: /tmp/trailer/.inprogress_trailer_test.mpg
>
org.apache.camel.component.file.GenericFileOperationFailedException:
Cannot
> store file: /tmp/trailer/.inprogress_trailer_test.mpg
> at
>
org
.apache
.camel.component.file.FileOperations.storeFile(FileOperations.java:
203)
> at
>
org
.apache
.camel
.component
.file.GenericFileProducer.writeFile(GenericFileProducer.java:144)
> at
>
org
.apache
.camel
.component
.file.GenericFileProducer.processExchange(GenericFileProducer.java:86)
> at
>
org
.apache
.camel
.component.file.GenericFileProducer.process(GenericFileProducer.java:
57)
> at
> org.apache.camel.processor.SendProcessor
$1.doInProducer(SendProcessor.java:81)
> at
> org.apache.camel.processor.SendProcessor
$1.doInProducer(SendProcessor.java:79)
> at
>
org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:
141)
> at
>
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:
78)
> at
>
org
.apache
.camel
.management
.InstrumentationProcessor.process(InstrumentationProcessor.java:61)
> at
>
org
.apache
.camel
.processor
.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:
186)
> at
>
org
.apache
.camel
.processor
.RedeliveryErrorHandler
.processErrorHandler(RedeliveryErrorHandler.java:155)
> at
>
org
.apache
.camel
.processor
.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
> at
>
org
.apache
.camel
.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
> at
>
org
.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:
148)
> at
org.apache.camel.processor.Pipeline.process(Pipeline.java:74)
> at
>
org
.apache
.camel
.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:
70)
> at
>
org
.apache
.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48)
> at
>
org
.apache
.camel.component.direct.DirectProducer.process(DirectProducer.java:45)
> at
> org.apache.camel.processor.SendProcessor
$1.doInProducer(SendProcessor.java:81)
> at
> org.apache.camel.processor.SendProcessor
$1.doInProducer(SendProcessor.java:79)
> at
>
org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:
141)
> at
>
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:
78)
> at
>
org
.apache
.camel
.management
.InstrumentationProcessor.process(InstrumentationProcessor.java:61)
> at
>
org
.apache
.camel
.processor
.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:
186)
> at
>
org
.apache
.camel
.processor
.RedeliveryErrorHandler
.processErrorHandler(RedeliveryErrorHandler.java:155)
> at
>
org
.apache
.camel
.processor
.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
> at
>
org
.apache
.camel
.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
> at
>
org
.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:
148)
> at
org.apache.camel.processor.Pipeline.process(Pipeline.java:74)
> at
>
org
.apache
.camel
.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:
54)
> at
>
org
.apache
.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48)
> at
>
org
.apache
.camel
.component
.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:
198)
> at
>
org
.apache
.camel
.component
.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:120)
> at
>
org
.apache
.camel
.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:93)
> at
>
org
.apache
.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:99)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:
417)
> at
> java.util.concurrent.FutureTask
$Sync.innerRunAndReset(FutureTask.java:280)
> at
java.util.concurrent.FutureTask.runAndReset(FutureTask.java:135)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor
$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:65)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor
$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:142)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor
$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:166)
> at
> java.util.concurrent.ThreadPoolExecutor
$Worker.runTask(ThreadPoolExecutor.java:650)
> at
> java.util.concurrent.ThreadPoolExecutor
$Worker.run(ThreadPoolExecutor.java:675)
> at java.lang.Thread.run(Thread.java:613)
> Caused by: org.apache.camel.InvalidPayloadException: No body
available of
> type: java.io.InputStream but has value: [bean:trailerHandler] of
type:
> java.util.ArrayList on: Message: [bean:trailerHandler]. Caused by:
No type
> converter available to convert from type: java.util.ArrayList to the
> required type: java.io.InputStream with value
[bean:trailerHandler] on the
> exchange: Exchange[Message: [bean:trailerHandler]]
> at
>
org
.apache
.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:104)
> at
>
org
.apache
.camel.util.ExchangeHelper.getMandatoryInBody(ExchangeHelper.java:136)
> at
>
org
.apache
.camel.component.file.FileOperations.storeFile(FileOperations.java:
197)
> ... 43 more
> Caused by: org.apache.camel.NoTypeConversionAvailableException: No
type
> converter available to convert from type: java.util.ArrayList to the
> required type: java.io.InputStream with value [bean:trailerHandler]
> at
>
org
.apache
.camel
.impl
.converter
.DefaultTypeConverter.mandatoryConvertTo(DefaultTypeConverter.java:
119)
> at
>
org
.apache
.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:102)
> ... 45 more
>
>
--
Claus Ibsen
Apache Camel Committer
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
Read more…
