允许 Camel 上下文永远运行 [英] Allow Camel context to run forever

问题描述

我正在为 springCamelContext 使用骆驼弹簧罐.当我启动骆驼上下文时，它会运行 5 分钟(默认时间).我可以让我的线程休眠一段时间，即

I am using camel-spring jar for springCamelContext. When I start the camel context , it run for 5 minutes (Default time). I can make my thread sleep for some specific time i.e.

try {
            camelContext.start();
            Thread.sleep(50 * 60 * 1000);
            camelContext.stop();
        } catch (Exception e) {
            e.printStackTrace();
        }

但我想让我的camelContext永远运行，因为这个应用程序将被部署并且它将监听来自KAFKA服务器的消息.我知道有一堂课

BUT I want is my camelContext to run FOREVER because this application is going to be deployed and It will be listening for messages from KAFKA server. I know there is a class

org.apache.camel.spring.Main

但我不知道如何使用 springCamelContext 配置它，或者不确定是否还有其他方法.谢谢

But I don't know how to configure it with springCamelContext or not sure if there any other way. Thanks

更新:即使我删除了 camelContext.stop() ，上下文也会在一段时间后停止，我会收到以下日志:

Update : Even If I remove camelContext.stop() , context is stopped after sometime and I get following logs :

[Thread-1] INFO org.apache.camel.spring.SpringCamelContext - Apache Camel 2.17.2 (CamelContext: camel-1) is shutting down
    [Thread-1] INFO org.apache.camel.impl.DefaultShutdownStrategy - Starting to graceful shutdown 1 routes (timeout 300 seconds)
    [Camel (camel-1) thread #1 - ShutdownTask] INFO org.apache.camel.component.kafka.KafkaConsumer - Stopping Kafka consumer
    [Camel (camel-1) thread #1 - ShutdownTask] INFO org.apache.camel.impl.DefaultShutdownStrategy - Route: route1 shutdown complete, was consuming from: Endpoint[kafka://localhost:9092?groupId=group0&serializerClass=org.springframework.integration.kafka.serializer.avro.AvroSerializer&topic=my-topic]
    [Thread-1] INFO org.apache.camel.impl.DefaultShutdownStrategy - Graceful shutdown of 1 routes completed in 0 seconds
    [Thread-1] INFO org.apache.camel.spring.SpringCamelContext - Apache Camel 2.17.2 (CamelContext: camel-1) uptime 4 minutes
    [Thread-1] INFO org.apache.camel.spring.SpringCamelContext - Apache Camel 2.17.2 (CamelContext: camel-1) is shutdown in 0.022 seconds 

推荐答案

这是一个永远运行并且只将文件从一个文件夹复制到另一个文件夹的最小示例:

Here is a minimal example which runs forever and only copies files from one folder to another:

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.main.Main;

public class FileWriteRoute {

    public static void main(String[] args) throws Exception {

        Main main = new Main();

        main.addRouteBuilder(new RouteBuilder() {

            public void configure() {
                from("file://D:/dev/playground/camel-activemq/src/data")
                        .to("file://D:/dev/playground/camel-activemq/src/data_out");
            }
        });

        main.run();
    }
}

这篇关于允许 Camel 上下文永远运行的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！