Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-12553

Box upload action's "filename from file" only works with FTP connector

    XMLWordPrintable

Details

    Description

      The box upload action can use the same filename from the file from previous step:

      However, this only works if the previous step is FTP, and it doesn't work with S3 or DropBox where it fails during the runtime with:

      {"exchange":"i-LwNgzoebaekheyxNLcCz","status":"begin"}
      {"exchange":"i-LwNgzoebaekheyxNLcCz","step":"30f46070-cf46-4f82-a1cf-ba4d7404ba79","id":"i-LwNgzofbaekheyxNLcDz","duration":84663}
      2019-12-18 11:10:46.572 ERROR 1 --- [bucket-from-x7r] o.a.camel.processor.DefaultErrorHandler  : Failed delivery for (MessageId: i-LwNgzofbaekheyxNLcEz on ExchangeId: i-LwNgzoebaekheyxNLcCz). Exhausted after delivery attempt: 1 caught: org.apache.camel.InvalidPayloadException: No body available of type: org.apache.camel.component.file.GenericFile but has value: org.apache.camel.converter.stream.InputStreamCache@675e5dd4 of type: org.apache.camel.converter.stream.InputStreamCache on: Message[i-LwNgzofbaekheyxNLcEz]. Caused by: No type converter available to convert from type: org.apache.camel.converter.stream.InputStreamCache to the required type: org.apache.camel.component.file.GenericFile with value org.apache.camel.converter.stream.InputStreamCache@675e5dd4. Exchange[i-LwNgzoebaekheyxNLcCz]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: org.apache.camel.converter.stream.InputStreamCache to the required type: org.apache.camel.component.file.GenericFile with value org.apache.camel.converter.stream.InputStreamCache@675e5dd4]
      
      Message History
      ---------------------------------------------------------------------------------------------------------------------------------------
      RouteId              ProcessorId          Processor                                                                        Elapsed (ms)
      [88854cd4-84db-4922] [88854cd4-84db-4922] [aws-s3://syndesis-server-bucket-from-x7r?accessKey=RAW(AKIAIEEBY2PHYAUTXZNQ)&d] [         2]
      [88854cd4-84db-4922] [step:30f46070-cf46] [pipeline                                                                      ] [         0]
      [88854cd4-84db-4922] [setHeader1        ] [setHeader[Syndesis.STEP_ID]                                                   ] [         0]
      [88854cd4-84db-4922] [setHeader2        ] [setHeader[Syndesis.FLOW_ID]                                                   ] [         0]
      [88854cd4-84db-4922] [setHeader3        ] [setHeader[Syndesis.STEP_ID]                                                   ] [         0]
      [88854cd4-84db-4922] [capture-out:30f460] [Processor@0x110cb3f8                                                          ] [         0]
      [88854cd4-84db-4922] [step:52548b16-ca57] [pipeline                                                                      ] [         0]
      [88854cd4-84db-4922] [setHeader4        ] [setHeader[Syndesis.STEP_ID]                                                   ] [         0]
      [88854cd4-84db-4922] [to1               ] [box-0-1                                                                       ] [         0]
      
      Stacktrace
      ---------------------------------------------------------------------------------------------------------------------------------------
      
      org.apache.camel.InvalidPayloadException: No body available of type: org.apache.camel.component.file.GenericFile but has value: org.apache.camel.converter.stream.InputStreamCache@675e5dd4 of type: org.apache.camel.converter.stream.InputStreamCache on: Message[i-LwNgzofbaekheyxNLcEz]. Caused by: No type converter available to convert from type: org.apache.camel.converter.stream.InputStreamCache to the required type: org.apache.camel.component.file.GenericFile with value org.apache.camel.converter.stream.InputStreamCache@675e5dd4. Exchange[i-LwNgzoebaekheyxNLcCz]. Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: org.apache.camel.converter.stream.InputStreamCache to the required type: org.apache.camel.component.file.GenericFile with value org.apache.camel.converter.stream.InputStreamCache@675e5dd4]
      	at org.apache.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:117) ~[camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at io.syndesis.connector.box.customizer.BoxUploadCustomizer.beforeProducer(BoxUploadCustomizer.java:43) ~[connector-box-1.9.1-20191217.jar!/:1.9.1-20191217]
      	at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61) ~[camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at io.syndesis.integration.component.proxy.ComponentProxyProducer.process(ComponentProxyProducer.java:44) ~[integration-component-proxy-1.9.1-20191217.jar!/:1.9.1-20191217]
      	at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) ~[camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at io.syndesis.integration.runtime.logging.ActivityTrackingInterceptStrategy$TrackDoneEventProcessor.process(ActivityTrackingInterceptStrategy.java:120) [integration-runtime-1.9.1-20191217.jar!/:1.9.1-20191217]
      	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:110) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:138) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.processor.Pipeline.process(Pipeline.java:101) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.component.aws.s3.S3Consumer.processBatch(S3Consumer.java:171) [camel-aws-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.component.aws.s3.S3Consumer.poll(S3Consumer.java:104) [camel-aws-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:174) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:101) [camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_191]
      	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_191]
      	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_191]
      	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [na:1.8.0_191]
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_191]
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_191]
      	at java.lang.Thread.run(Thread.java:748) [na:1.8.0_191]
      Caused by: org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: org.apache.camel.converter.stream.InputStreamCache to the required type: org.apache.camel.component.file.GenericFile with value org.apache.camel.converter.stream.InputStreamCache@675e5dd4
      	at org.apache.camel.impl.converter.BaseTypeConverterRegistry.mandatoryConvertTo(BaseTypeConverterRegistry.java:205) ~[camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	at org.apache.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:115) ~[camel-core-2.23.2.fuse-760009.jar!/:2.23.2.fuse-760009]
      	... 32 common frames omitted
      
      

      Attachments

        Issue Links

          Activity

            People

              cmiranda@redhat.com Claudio Miranda
              avano@redhat.com Andrej Vano
              Andrej Vano Andrej Vano
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: