整合Spring XML上下文与Apache Camel 3.x实现长时运行应用

package com.foo.email.ffdb.listener;

import java.util.Properties;
import javax.annotation.Resource;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.spring.Main; // Camel 2.x 使用的 Main 类
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;

// ... 其他导入

public class EmailDBListener extends RouteBuilder {
    private static Logger log = LogManager.getLogger(EmailDBListener.class.getName());
    private static String routeId = "EMAIL_ROUTE_ID"; // 简化常量

    @Autowired
    private EmailDBProcessor emaiDBProcessor;

    @Resource
    private Properties emailProperties;

    public static void main(String[] args) throws Exception {
        System.out.println("STARTING EMAILDBLISTENER");
        log.debug("Starting Email Batch ");
        Main main = new Main();
        main.setApplicationContextUri("app-context.xml"); // 加载Spring XML上下文
        main.run(); // 启动并保持运行
        log.info("Email Batch Started:"); // 这行代码通常在 main.run() 阻塞后不会立即执行
    }

    @Override
    public void configure() throws Exception {
        log.debug("configure() ");
        from(configureSqlTimer())
        .routeId(routeId)
        .to("sqlComponent:{{SQL.READ_EMAIL_REQUESTS}}")
        .bean("fireForgetServiceMapper", "readEmailRequests")
        .process(emaiDBProcessor);
    }

    private String configureSqlTimer() {
        log.debug("configureSqlTimer() ");
        String pollingTime = emailProperties.getProperty("POLLING_TIME"); // 简化常量
        String sqlTimer = "timer://pollFireFrgtTable?period=" + pollingTime + "s";
        return sqlTimer;
    }
}

package com.foo.email.ffdb.listener;

import java.util.Properties;
import javax.annotation.Resource;
import org.apache.camel.builder.RouteBuilder;
// 关键：确保导入的是 org.apache.camel.spring.Main
import org.apache.camel.spring.Main;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;

// ... 其他导入

public class EmailDBListener extends RouteBuilder {
    private static final Logger log = LogManager.getLogger(EmailDBListener.class.getName());
    private static final String routeId = "EMAIL_ROUTE_ID"; // 简化常量

    @Autowired
    private EmailDBProcessor emaiDBProcessor; // 假设这是一个Spring Bean

    @Resource
    private Properties emailProperties; // 假设这是一个Spring Bean

    public static void main(String[] args) throws Exception {
        System.out.println("STARTING EMAILDBLISTENER");
        log.debug("Starting Email Batch ");

        // 在Camel 3.x中，用于Spring XML集成的正确Main类
        Main main = new Main();
        main.setApplicationContextUri("app-context.xml"); // 加载Spring XML上下文
        main.run(); // 启动并保持应用程序运行，直到接收到停止信号

        log.info("Email Batch Started:"); // 这行代码在应用程序运行期间不会被执行
    }

    @Override
    public void configure() throws Exception {
        log.debug("configure() ");
        from(configureSqlTimer())
            .routeId(routeId)
            .to("sqlComponent:{{SQL.READ_EMAIL_REQUESTS}}")
            .bean("fireForgetServiceMapper", "readEmailRequests") // fireForgetServiceMapper 假设是Spring Bean
            .process(emaiDBProcessor); // emaiDBProcessor 假设是Spring Bean
    }

    private String configureSqlTimer() {
        log.debug("configureSqlTimer() ");
        String pollingTime = emailProperties.getProperty("POLLING_TIME"); // 简化常量
        String sqlTimer = "timer://pollFireFrgtTable?period=" + pollingTime + "s";
        return sqlTimer;
    }
}

<dependencies>
    <!-- Camel Spring Main 构件，用于Spring XML集成 -->
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-spring-main</artifactId>
        <version>3.14.0</version> <!-- 使用你的目标Camel版本 -->
    </dependency>

    <!-- 根据你的路由需要，添加其他Camel组件依赖，例如 camel-sql, camel-timer -->
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-sql</artifactId>
        <version>3.14.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-timer</artifactId>
        <version>3.14.0</version>
    </dependency>

    <!-- 如果你的Spring XML配置文件使用了Spring核心功能，请确保包含 spring-context -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.3.14</version> <!-- 或与你的Camel版本兼容的Spring版本 -->
    </dependency>

    <!-- 其他项目依赖，例如日志库 -->
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-api</artifactId>
        <version>2.17.1</version>
    </dependency>
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-core</artifactId>
        <version>2.17.1</version>
    </dependency>
</dependencies>