异常处理骆驼

Question

我正在尝试从目录中选取一个文件，拆分一个文件，并将每一个拆分行添加到ActiveMQ中。我在这个过程中遇到了异常处理的问题。假设目录中的文件是一个二进制文件（可执行文件），那么splitter会显示org.apache.camel.runtimeCamelException和java.nio.charset.MalFormedInputException异常。如果出现这种情况，那么我需要捕获这些异常，在activemq中不应该添加任何内容，并且只有特定的线程应该在记录异常之后退出。在线参考并编写了以下代码，但不知道如何停止添加到activemq并退出特定线程。

<route id="msg_producer">
        <from uri="input.file.from" />
        <doTry>
        <split parallelProcessing="true" executorServiceRef="msgProducer"
            streaming="true">
            <tokenize token="\n"></tokenize>
            <to uri="input.activemq.to" />
        </split>
        <doCatch>
            <exception>org.apache.camel.RuntimeCamelException</exception>
            <exception>java.nio.charset.MalformedInputException</exception>
                <handled> <constant>true</constant></handled>
                <setBody>
                    <simple>${exception.stacktrace}</simple>
                </setBody>
                <setHeader headerName="CamelFileName">
                    <simple>${file:onlyname.noext}_error.log</simple>
                </setHeader>
        </doCatch>
        </doTry>
    </route>

Answer 1

正如@Claus Ibsen所说的，为了过滤文件，您可以使用filefilter属性，这样您就可以根据扩展名和一些标准模式来选择文件

    <bean id="FileFilter" class="org.apache.camel.component.file.AntPathMatcherGenericFileFilter">
    <!--        ?   matches one character
                *   matches zero or more characters
                **  matches zero or more directories in a path -->
    <property name="includes" value="#{databaseProperties.getProperties().getProperty('file.name.pattern')}"/>
    <!-- if you wan to exclude specific files say bad in name or .exe files. Use comma to separate multiple excludes -->
    <!-- <property name="excludes" value="**/*bad*,**/*.exe"/> -->
    </bean>

而您的file.name.pattern可以是类似于**/contract.csv的格式