【发布时间】:2016-07-06 09:37:23
【问题描述】:
我使用 spring-integration FileSplitter 并使用 FileMarker-s 进行有序处理文件,但对于空文件我得到 IOException。没有 FileMarker-s 一切正常
堆栈跟踪:
Caused by: java.io.IOException: Stream closed
at java.io.BufferedReader.ensureOpen(BufferedReader.java:122)
at java.io.BufferedReader.readLine(BufferedReader.java:317)
at java.io.BufferedReader.readLine(BufferedReader.java:389)
at org.springframework.integration.file.splitter.FileSplitter$1.hasNext(FileSplitter.java:183)
... 50 more
xml-配置:
<int:chain input-channel="channel.read.file" output-channel="channel.process.input">
<int-file:splitter markers="true"/>
<int:filter expression="!(payload instanceof T(org.springframework.integration.file.splitter.FileSplitter.FileMarker))"
discard-channel="channel.process.file.marker"/>
</int:chain>
【问题讨论】:
标签: java spring spring-integration