[
https://issues.apache.org/jira/browse/CAMEL-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Claus Ibsen resolved CAMEL-15558.
---------------------------------
Resolution: Fixed
> pollEnrich timeout issue
> ------------------------
>
> Key: CAMEL-15558
> URL: https://issues.apache.org/jira/browse/CAMEL-15558
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 3.4.3, 3.5.0
> Reporter: ncasaux
> Priority: Major
> Fix For: 3.6.0, 3.4.5
>
>
> Hello !
> I’m trying to use this simple route with Camel 3.4.3 and springboot :
> {code:java}
> from("timer:hello?repeatCount=1&delay=1000").routeId("hello")
> .to("log:1")
> .pollEnrich("file:d:\\temp?noop=true&fileName=dummy.csv",5000)
> .to("log:2");{code}
> I run it without the file dummy.csv, to test the timeout option.
> The timeout functionality does not seem to work, as you can see in the log,
> there’s no delay between log1 and log2:
>
> {code:java}
> 2020-09-19 11:39:30.099 INFO 186564 --- [- timer://hello] 1
> : Exchange[ExchangePattern: InOnly, BodyType: null,
> Body: [Body is null]]
> 2020-09-19 11:39:30.107 INFO 186564 --- [- timer://hello]
> o.a.camel.component.file.FileEndpoint : Endpoint is configured with
> noop=true so forcing endpoint to be idempotent as well
> 2020-09-19 11:39:30.107 INFO 186564 --- [- timer://hello]
> o.a.camel.component.file.FileEndpoint : Using default memory based
> idempotent repository with cache max size: 1000
> 2020-09-19 11:39:30.208 INFO 186564 --- [- timer://hello] 2
> : Exchange[ExchangePattern: InOnly, BodyType: null,
> Body: [Body is null]]
> {code}
>
> However, with Camel 2.24.3 It seems to work as expected as we can see the 5
> sec delay between log1 and log2:
>
> {code:java}
> 2020-09-19 11:38:50.242 INFO 151696 --- [- timer://hello] 1
> : Exchange[ExchangePattern: InOnly, BodyType: null,
> Body: [Body is null]]
> 2020-09-19 11:38:50.244 INFO 151696 --- [- timer://hello]
> o.a.camel.processor.interceptor.Tracer : ID-ITEM-S74991-1600508328077-0-1
> >>> (hello) log://1 -->
> pollEnrich[constant{file:d:\temp?noop=true&fileName=dummy.csv}] <<<
> Pattern:InOnly, Headers:{breadcrumbId=ID-ITEM-S74991-1600508328077-0-1,
> firedTime=Sat Sep 19 11:38:50 CEST 2020}, BodyType:null, Body:[Body is null]
> 2020-09-19 11:38:50.259 INFO 151696 --- [- timer://hello]
> o.a.camel.component.file.FileEndpoint : Endpoint is configured with
> noop=true so forcing endpoint to be idempotent as well
> 2020-09-19 11:38:50.259 INFO 151696 --- [- timer://hello]
> o.a.camel.component.file.FileEndpoint : Using default memory based
> idempotent repository with cache max size: 1000
> 2020-09-19 11:38:55.355 INFO 151696 --- [- timer://hello]
> o.a.camel.processor.interceptor.Tracer : ID-ITEM-S74991-1600508328077-0-1
> >>> (hello) pollEnrich[constant{file:d:\temp?noop=true&fileName=dummy.csv}]
> --> log://2 <<< Pattern:InOnly,
> Headers:{breadcrumbId=ID-ITEM-S74991-1600508328077-0-1,
> CamelToEndpoint=file://d:%5Ctemp?fileName=dummy.csv&noop=true, firedTime=Sat
> Sep 19 11:38:50 CEST 2020}, BodyType:null, Body:[Body is null]
> 2020-09-19 11:38:55.355 INFO 151696 --- [- timer://hello] 2
> : Exchange[ExchangePattern: InOnly, BodyType: null,
> Body: [Body is null]]
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
