BeanIOとApache Camelを使用したUnmarshal InputStream

Question

ファイルを受信して​​Camelルートに送信するサービスがあります。そのルートでは、BeanIOを使ってそのファイルを非整列化したいが、それはInputStream型の入力を認識しない。

@RestController 
@RequestMapping(value = "/file") 
public class FileController { 

    @Autowired 
    private CamelContext camelContext; 

    @RequestMapping(value = "/upload", method = RequestMethod.POST) 
    public void upload(@RequestParam("file") MultipartFile multipartFile) throws IOException { 
     ProducerTemplate template = camelContext.createProducerTemplate(); 
     template.sendBody("direct:routeTest", new ByteArrayInputStream(multipartFile.getBytes())); 
    } 

} 

@Component 
public class SampleRouter extends RouteBuilder { 

    @Override 
    public void configure() throws Exception { 
     from("direct:routeTest") 
       .log("${body}") 
       .to("dataformat:beanio:unmarshal?mapping=mapping.xml&streamName=testFile") 
       .process(msg -> msg.getIn() 
         .getBody(List.class) 
         .forEach(o -> {...})) 
       .end(); 
    } 

} 

Fileコンポーネントを使用してファイルを読み取るルートをテストし、その結果をBeanIOコンポーネントに送信しました。その場合は動作します。

Apache CamelでInputStream型の入力でBeanIOを使用するにはどうすればよいですか？ InputStreamをBeanIOコンポーネントと互換性のあるものに変換できるコンポーネントはありますか？

Answer 1

その他の解決策は、.streamCaching()をルートに追加することができます。その後、同じストリームを複数回読み取ることができます。 Official documentation

Answer 2

mgyongyosiが言ったように、.log("${body}")がストリームを読み込むと、その位置はその最後に行きます。

from("direct:routeTest") 
     .log("${body}") 
     .process(exchange -> ((InputStream) exchange.getIn().getBody()).reset()) 
     .to("dataformat:beanio:unmarshal?mapping=mapping.xml&streamName=testFile") 

またはライン.log("${body}")を削除する：これを解決するために、我々はそれを読んだ後InputStreamの位置をリセットすることができます。