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.
