[CAMEL-9152] Camel streaming component doesn't close a stream when last exchange is not passed to the endpoint

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 2.14.1
• Component/s: camel-stream
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Bohdan Zhezlo
• Created: 22/Sep/15 13:30
• Updated: 24/Sep/15 16:10
• Resolved: 24/Sep/15 15:08

Description

Here is sample test which reproduces the problem:

route.from("direct:foo")
    .split().tokenize("\n").streaming()
    .choice()
        .when(body().isEqualTo(9))
        .stop()
     .otherwise()
         .to("stream:file?fileName=streaming.txt&closeOnDone=true")
     .endChoice();

@Produce(uri = "direct:foo")
protected ProducerTemplate template;

StringBuilder builder = new StringBuilder();
for(int i = 0; i < 10; i++) {
   builder.append(i);
   builder.append("\n");
}

template.sendBody(builder.toString());

File file = new File("streaming.txt");
boolean exists = file.exists();
boolean deleted = file.delete();

After running sample test 'deleted' will be false and file is present on file system, which indicates that the file stream was not closed.

If I modify condition in the route so that no exchanges get skipped (or if I skip any exchange except the last one) then file is successfully deleted.