当Apache Camel FTP路由出现连接错误时，如何关闭并抛出异常？

Question

我有以下Apache Camel FTP文件下载路径：

        from(downloadUri)
            .routeId(routeId)
            .aggregate(new CustomListAggregationStrategy())
            .constant(true)
            .completionFromBatchConsumer()
            .to("direct:" + routeDestinationId);

我将此路由添加到上下文，然后使用ConsumerTemplate请求数据：

List<ResultType> result = consumerTemplate.receiveBody(CAMEL_DIRECT_OBJECT_PREFIX
                        + routeId, List.class);

当出现连接错误时(例如，未知的主机、无法到达的主机)，我想关闭路由，并在“receiveBody”行后抛出一个异常，在那里我试图读取下载的文件。

我该怎么做呢？

我为路由尝试了一个onException-handler，在其中添加了一个流程块，并调用了exchange.getContext()。stop()；在那个处理块中。但是应用程序一直在运行。

Answer 1

在路由现有消息的过程中停止路由有点棘手。原因是骆驼会优雅地关闭你要停的路线。如果您在消息被路由时这样做，正常关机将尝试等待消息被处理。

您可以在这里找到更多信息:https://camel . Apache . org/manual/FAQ/how-can-I-stop-a-route-from-a-route . html