Hi, I think your "bar" header isn't set or I don't understand what you want to do. When you read a file from the file component of Camel, Camel won't set a "bar" header for you.
The camel file component will set some header but not the "bar" one. Arnaud Deprez -----Original Message----- From: Gnanaguru S [mailto:gnanaguru.sattanat...@wipro.com] Sent: mardi 2 octobre 2012 14:27 To: users@camel.apache.org Subject: Re: Camel Twitter - Filter through message body I understood. I tried the following producer. I tried to take the keyword from a file. ( Will my logic work ? I kept a keyword in a simple text file) from("file://u:/take?noop=true") .setHeader("CamelTwitterKeywords", header("bar")) .to("twitter://search") .to("websocket:camel-tweet?sendToAll=true"); I have configured the auth tokens, No issues with that. I am getting this exception. at java.lang.Thread.run(Thread.java:662) [-1) thread #0 - file://u:/take] GenericFileOnCompletion WARN Rollback f ile strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessS trategy@28b7f2d0 for file: GenericFile[u:\take\Data.txt] [-1) thread #0 - file://u:/take] DefaultErrorHandler ERROR Failed del ivery for (MessageId: ID-Guru-PC-65468-1349180777016-0-11 on ExchangeId: ID-Guru -PC-65468-1349180777016-0-12). Exhausted after delivery attempt: 1 caught: org.a pache.camel.CamelExchangeException: No keywords to use for query. Exchange[Data. txt] org.apache.camel.CamelExchangeException: No keywords to use for query. Exchange[ Data.txt] at org.apache.camel.component.twitter.producer.SearchProducer.process(Se archProducer.java:48) at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncP rocessorBridge.process(AsyncProcessorConverterHelper.java:61) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProc essor.java:120) at org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.j ava:292) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:1 15) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(Delegat eAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.management.InstrumentationProcessor.process(Instrume ntationProcessor.java:73) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(Delegat eAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.processor.interceptor.TraceInterceptor.process(Trace Interceptor.java:91) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler (RedeliveryErrorHandler.java:330) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryE rrorHandler.java:220) at org.apache.camel.processor.RouteContextProcessor.processNext(RouteCon textProcessor.java:45) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.processor.interceptor.DefaultChannel.process(Default Channel.java:303) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.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(RouteCon textProcessor.java:45) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWor kProcessor.java:150) at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProc essor.java:117) at org.apache.camel.processor.RouteInflightRepositoryProcessor.processNe xt(RouteInflightRepositoryProcessor.java:48) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(Delegat eAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.management.InstrumentationProcessor.process(Instrume ntationProcessor.java:73) at org.apache.camel.component.file.GenericFileConsumer.processExchange(G enericFileConsumer.java:336) at org.apache.camel.component.file.GenericFileConsumer.processBatch(Gene ricFileConsumer.java:189) at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileC onsumer.java:155) at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsum er.java:139) at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer .java:91) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:44 1) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java :317) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask. access$101(ScheduledThreadPoolExecutor.java:98) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask. runPeriodic(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask. run(ScheduledThreadPoolExecutor.java:204) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec utor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:908) at java.lang.Thread.run(Thread.java:662) [-1) thread #0 - file://u:/take] GenericFileOnCompletion WARN Rollback f ile strategy: org.apache.camel.component.file.strategy.GenericFileRenameProcessS trategy@28b7f2d0 for file: GenericFile[u:\take\Data.txt] [-1) thread #0 - file://u:/take] DefaultErrorHandler ERROR Failed del ivery for (MessageId: ID-Guru-PC-65468-1349180777016-0-13 on ExchangeId: ID-Guru -PC-65468-1349180777016-0-14). Exhausted after delivery attempt: 1 caught: org.a pache.camel.CamelExchangeException: No keywords to use for query. Exchange[Data. txt] org.apache.camel.CamelExchangeException: No keywords to use for query. Exchange[ Data.txt] at org.apache.camel.component.twitter.producer.SearchProducer.process(Se archProducer.java:48) at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncP rocessorBridge.process(AsyncProcessorConverterHelper.java:61) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProc essor.java:120) at org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.j ava:292) at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:1 15) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(Delegat eAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.management.InstrumentationProcessor.process(Instrume ntationProcessor.java:73) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(Delegat eAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.processor.interceptor.TraceInterceptor.process(Trace Interceptor.java:91) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler (RedeliveryErrorHandler.java:330) at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryE rrorHandler.java:220) at org.apache.camel.processor.RouteContextProcessor.processNext(RouteCon textProcessor.java:45) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.processor.interceptor.DefaultChannel.process(Default Channel.java:303) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.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(RouteCon textProcessor.java:45) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWor kProcessor.java:150) at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProc essor.java:117) at org.apache.camel.processor.RouteInflightRepositoryProcessor.processNe xt(RouteInflightRepositoryProcessor.java:48) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp er.java:73) at org.apache.camel.processor.DelegateAsyncProcessor.processNext(Delegat eAsyncProcessor.java:99) at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy ncProcessor.java:90) at org.apache.camel.management.InstrumentationProcessor.process(Instrume ntationProcessor.java:73) at org.apache.camel.component.file.GenericFileConsumer.processExchange(G enericFileConsumer.java:336) at org.apache.camel.component.file.GenericFileConsumer.processBatch(Gene ricFileConsumer.java:189) at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileC onsumer.java:155) at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsum er.java:139) at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer .java:91) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:44 1) at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java :317) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:150) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask. access$101(ScheduledThreadPoolExecutor.java:98) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask. runPeriodic(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask. run(ScheduledThreadPoolExecutor.java:204) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExec utor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor .java:908) Regards Guru -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Twitter-Filter-through-message-body-tp5720356p5720363.html Sent from the Camel - Users mailing list archive at Nabble.com. Atos Worldline SA/NV - Chaussee de Haecht 1442 Haachtsesteenweg - 1130 Brussels - Belgium RPM-RPR Bruxelles-Brussel - TVA-BTW BE 0418.547.872 Bankrekening-Compte Bancaire-Bank Account 310-0269424-44 BIC BBRUBEBB - IBAN BE55 3100 2694 2444 "The information contained in this e-mail and any attachment thereto is confidential and may contain information which is protected by intellectual property rights. This information is intended for the exclusive use of the recipient(s) named above. This e-mail does not constitute any binding relationship or offer toward any of the addressees. If you are not one of the addressees , one of their employees or a proxy holder entitled to hand over this message to the addressee(s), any use of the information contained herein (e.g. reproduction, divulgation, communication or distribution,...) is prohibited. If you have received this message in error, please notify the sender and destroy it immediately after. The integrity and security of this message cannot be guaranteed and it may be subject to data corruption, interception and unauthorized amendment, for which we accept no liability."
