Uploaded image for project: 'Camel'
  1. Camel
  2. CAMEL-15558

pollEnrich timeout issue

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 3.4.3, 3.5.0
    • Fix Version/s: 3.6.0, 3.4.5
    • Component/s: camel-core
    • Labels:
      None
    • Estimated Complexity:
      Unknown
    • Regression:
      Regression

      Description

      Hello !

       I’m trying to use this simple route with Camel 3.4.3 and springboot :

       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");

       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:

       

       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]]
      

       

       However, with Camel 2.24.3  It seems to work as expected as we can see the 5 sec delay between log1 and log2:

       

       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]]
      

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                ncasaux ncasaux
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: