search

krasserm / streamz

A combinator library for integrating Functional Streams for Scala (FS2), Akka Streams and Apache Camel
Apache License 2.0
282 stars 44 forks source link

Example.scala fails to read files from Camel file component #37

Closed searler closed 7 years ago

searler commented 7 years ago

The 

 val fileEndpointUri: String =
    "file:input?charset=utf-8"

must be changed to

 val fileEndpointUri: String =
    "file:input?noop=true"

otherwise the file is moved before it can be read.

searler commented 7 years ago

Obviously most applications cannot be restricted to "noop=true"

krasserm commented 7 years ago

@searler thanks for reporting, that was a bug which is now fixed in master. Can you please give it a try? When working for you, I'll make a 0.8.1 release in the next days.

krasserm commented 7 years ago

If message conversion fails, the corresponding exception is also set on the inbound CamelExchange (akka-stream and FS2)

krasserm commented 7 years ago

that was a bug

I mean not the missing noop=true was the bug but the fact that it didn't work otherwise 😃

searler commented 7 years ago

Works now.

Thanks for the quick response

krasserm commented 7 years ago

You're welcome. I just released 0.8.1 with this bug fix.