camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Müller <christian.muel...@gmail.com>
Subject Re: File do ActiveMQ
Date Tue, 06 Nov 2012 23:45:36 GMT
Which version do you use?
Hoe does your route looks like?

Sent from a mobile device
Am 06.11.2012 19:29 schrieb "Leandro Franchi" <leandro.franchi@gmail.com>:

> Hi,
>
> I've a route to read files, convert the body to string and send to
> ActiveMQ. It's ok, but somentimes, I've got these error:
>
>
> 06/11/2012 16:19:19.174 [Camel (mirCamel) thread #21 - file:/tmp] ERROR
> org.apache.camel.processor.**FatalFallbackErrorHandler:55 - \--> New
> exception on exchangeId: ID-alxredmircol01-51775-**1352225432241-0-14234
>  org.apache.camel.**TypeConversionException: Error during type conversion
> from type: org.apache.camel.component.**file.GenericFile to the required
> type: byte[] with value GenericFile[/mnt/sox/HST/**20121030_174713_N.txt]
> due java.lang.**IllegalArgumentException: reader must be specified
>     at org.apache.camel.impl.**converter.**BaseTypeConverterRegistry.**
> convertTo(**BaseTypeConverterRegistry.**java:126)
>     at org.apache.camel.component.**jms.JmsBinding.**
> createJmsMessageForType(**JmsBinding.java:534)
>     at org.apache.camel.component.**jms.JmsBinding.**
> createJmsMessage(JmsBinding.**java:464)
>     at org.apache.camel.component.**jms.JmsBinding.makeJmsMessage(**
> JmsBinding.java:285)
>     at org.apache.camel.component.**jms.JmsProducer$2.**
> createMessage(JmsProducer.**java:266)
>     at org.apache.camel.component.**jms.JmsConfiguration$**
> CamelJmsTemplate.**doSendToDestination(**JmsConfiguration.java:214)
>     at org.apache.camel.component.**jms.JmsConfiguration$**
> CamelJmsTemplate.access$100(**JmsConfiguration.java:157)
>     at org.apache.camel.component.**jms.JmsConfiguration$**
> CamelJmsTemplate$3.doInJms(**JmsConfiguration.java:191)
>     at org.springframework.jms.core.**JmsTemplate.execute(**
> JmsTemplate.java:466)
>     at org.apache.camel.component.**jms.JmsConfiguration$**
> CamelJmsTemplate.send(**JmsConfiguration.java:188)
>     at org.apache.camel.component.**jms.JmsProducer.doSend(**
> JmsProducer.java:398)
>     at org.apache.camel.component.**jms.JmsProducer.processInOnly(**
> JmsProducer.java:352)
>     at org.apache.camel.component.**jms.JmsProducer.process(**
> JmsProducer.java:132)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**SendProcessor$2.**doInAsyncProducer(**
> SendProcessor.java:120)
>     at org.apache.camel.impl.**ProducerCache.**doInAsyncProducer(**
> ProducerCache.java:292)
>     at org.apache.camel.processor.**SendProcessor.process(**
> SendProcessor.java:115)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**processNext(*
> *DelegateAsyncProcessor.java:**99)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.management.**InstrumentationProcessor.**process(**
> InstrumentationProcessor.java:**73)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**processNext(*
> *DelegateAsyncProcessor.java:**99)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.processor.**interceptor.TraceInterceptor.**
> process(TraceInterceptor.java:**91)
>     at org.apache.camel.processor.**interceptor.**
> StreamCachingInterceptor.**process(**StreamCachingInterceptor.java:**52)
>     at org.apache.camel.processor.**RouteContextProcessor.**processNext(**
> RouteContextProcessor.java:45)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.processor.**interceptor.DefaultChannel.**
> process(DefaultChannel.java:**303)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**Pipeline.process(Pipeline.**java:117)
>     at org.apache.camel.processor.**Pipeline.process(Pipeline.**java:80)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**processNext(*
> *DelegateAsyncProcessor.java:**99)
>     at org.apache.camel.processor.**FatalFallbackErrorHandler.**
> processNext(**FatalFallbackErrorHandler.**java:42)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**RedeliveryErrorHandler.**
> deliverToFailureProcessor(**RedeliveryErrorHandler.java:**759)
>     at org.apache.camel.processor.**RedeliveryErrorHandler.**
> processErrorHandler(**RedeliveryErrorHandler.java:**273)
>     at org.apache.camel.processor.**RedeliveryErrorHandler.**process(**
> RedeliveryErrorHandler.java:**220)
>     at org.apache.camel.processor.**interceptor.**
> StreamCachingInterceptor.**process(**StreamCachingInterceptor.java:**52)
>     at org.apache.camel.processor.**RouteContextProcessor.**processNext(**
> RouteContextProcessor.java:45)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.processor.**interceptor.DefaultChannel.**
> process(DefaultChannel.java:**303)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**Pipeline.process(Pipeline.**java:117)
>     at org.apache.camel.processor.**Pipeline.process(Pipeline.**java:80)
>     at org.apache.camel.processor.**RouteContextProcessor.**processNext(**
> RouteContextProcessor.java:45)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.processor.**UnitOfWorkProcessor.**processAsync(**
> UnitOfWorkProcessor.java:150)
>     at org.apache.camel.processor.**UnitOfWorkProcessor.process(**
> UnitOfWorkProcessor.java:117)
>     at org.apache.camel.processor.**RouteInflightRepositoryProcess**
> or.processNext(**RouteInflightRepositoryProcess**or.java:48)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.util.**AsyncProcessorHelper.process(**
> AsyncProcessorHelper.java:73)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**processNext(*
> *DelegateAsyncProcessor.java:**99)
>     at org.apache.camel.processor.**DelegateAsyncProcessor.**process(**
> DelegateAsyncProcessor.java:**90)
>     at org.apache.camel.management.**InstrumentationProcessor.**process(**
> InstrumentationProcessor.java:**73)
>     at org.apache.camel.component.**file.GenericFileConsumer.**
> processExchange(**GenericFileConsumer.java:336)
>     at br.com.flexvision.mir.**collector.component.sw.file.**
> FileSwitchConsumer.**processExchange(**FileSwitchConsumer.java:26)
>     at org.apache.camel.component.**file.GenericFileConsumer.**
> processBatch(**GenericFileConsumer.java:189)
>     at org.apache.camel.component.**file.GenericFileConsumer.poll(**
> GenericFileConsumer.java:155)
>     at org.apache.camel.impl.**ScheduledPollConsumer.doRun(**
> ScheduledPollConsumer.java:**139)
>     at org.apache.camel.impl.**ScheduledPollConsumer.run(**
> ScheduledPollConsumer.java:91)
>     at java.util.concurrent.**Executors$RunnableAdapter.**
> call(Executors.java:471)
>     at java.util.concurrent.**FutureTask$Sync.**
> innerRunAndReset(FutureTask.**java:351)
>     at java.util.concurrent.**FutureTask.runAndReset(**
> FutureTask.java:178)
>     at java.util.concurrent.**ScheduledThreadPoolExecutor$**
> ScheduledFutureTask.access$**301(**ScheduledThreadPoolExecutor.**java:178)
>     at java.util.concurrent.**ScheduledThreadPoolExecutor$**
> ScheduledFutureTask.run(**ScheduledThreadPoolExecutor.**java:293)
>     at java.util.concurrent.**ThreadPoolExecutor.runWorker(**
> ThreadPoolExecutor.java:1110)
>     at java.util.concurrent.**ThreadPoolExecutor$Worker.run(**
> ThreadPoolExecutor.java:603)
>     at java.lang.Thread.run(Thread.**java:722)
> Caused by: org.apache.camel.**RuntimeCamelException: java.lang.**IllegalArgumentException:
> reader must be specified
>     at org.apache.camel.util.**ObjectHelper.**wrapRuntimeCamelException(**
> ObjectHelper.java:1280)
>     at org.apache.camel.util.**ObjectHelper.invokeMethod(**
> ObjectHelper.java:936)
>     at org.apache.camel.impl.**converter.**StaticMethodTypeConverter.**
> convertTo(**StaticMethodTypeConverter.**java:47)
>     at org.apache.camel.component.**file.GenericFileConverter.**convertTo(
> **GenericFileConverter.java:93)
>     at sun.reflect.**GeneratedMethodAccessor102.**invoke(Unknown Source)
>     at sun.reflect.**DelegatingMethodAccessorImpl.**invoke(**
> DelegatingMethodAccessorImpl.**java:43)
>     at java.lang.reflect.Method.**invoke(Method.java:601)
>     at org.apache.camel.util.**ObjectHelper.invokeMethod(**
> ObjectHelper.java:932)
>     at org.apache.camel.impl.**converter.**StaticMethodFallbackTypeConver*
> *ter.convertTo(**StaticMethodFallbackTypeConver**ter.java:50)
>     at org.apache.camel.impl.**converter.**BaseTypeConverterRegistry.**
> doConvertTo(**BaseTypeConverterRegistry.**java:289)
>     at org.apache.camel.impl.**converter.**BaseTypeConverterRegistry.**
> convertTo(**BaseTypeConverterRegistry.**java:111)
>     ... 70 more
> Caused by: java.lang.**IllegalArgumentException: reader must be specified
>     at org.apache.camel.util.**ObjectHelper.notNull(**
> ObjectHelper.java:290)
>     at org.apache.camel.util.**IOHelper.buffered(IOHelper.**java:117)
>     at org.apache.camel.converter.**IOConverter.toByteArray(**
> IOConverter.java:261)
>     at sun.reflect.**GeneratedMethodAccessor230.**invoke(Unknown Source)
>     at sun.reflect.**DelegatingMethodAccessorImpl.**invoke(**
> DelegatingMethodAccessorImpl.**java:43)
>     at java.lang.reflect.Method.**invoke(Method.java:601)
>     at org.apache.camel.util.**ObjectHelper.invokeMethod(**
> ObjectHelper.java:932)
>     ... 79 more
>
> Anyone have idea?
>
> Thanks
> Leandro Franchi
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message