使用apache camel java DSL从activemq接收消息

Question

• 我正在使用 apache camel 从队列中接收所有消息。但是我 需要提到线程的睡眠时间才能运行骆驼上下文。
• 现在的问题是它只消耗一些消息，即。内 指定睡眠时间。
• 如果我增加睡眠时间，那么它将路由所有消息，但是 它一直等到睡眠时间结束才终止程序。
• 我需要的是，骆驼应该路由队列中的所有消息 然后它应该立即终止。

有没有什么方法可以在不使用java DSL指定线程睡眠时间的情况下运行骆驼？

示例代码：

import javax.jms.ConnectionFactory;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.jms.JmsComponent;
import org.apache.camel.impl.DefaultCamelContext;

public class SplitJson {

    public static void main(String[] args) {

        try {
            CamelContext context = new DefaultCamelContext();
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "admin",
                    ActiveMQConnection.DEFAULT_BROKER_URL);
            context.addComponent("test-jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
            context.addRoutes(new RouteBuilder() {
                public void configure() {
                    from("test-jms:queue:testMQDestination")
                    .choice()
                    .when().jsonpath("$.[?(@.Status == 'YetToStart')]")
                    .to("test-jms:queue:YetToStart")
                    .when().jsonpath("$.[?(@.Status == 'Started')]]")
                    .to("test-jms:queue:Started")
                    .when().jsonpath("$.[?(@.Status == 'Completed')]]")
                    .to("test-jms:queue:Completed")
                    .otherwise()
                    .to("test-jms:queue:Others")
                    .end();
                }
            });
            context.start();
            Thread.sleep(10000);
            context.stop();
            System.out.println("Done");
        } catch (Exception e) {

            e.printStackTrace();
        }

    }

}

Answer 1

您需要构建自己的逻辑来检查 Camel 何时空闲并且该队列上没有更多消息。

您可以使用路由策略，然后在 onExchangeDone 中，您可以重置一个时钟，这是新消息进入时的事件。然后，如果在 X 周期之后没有新消息，则该时钟会超时或发生什么然后你就知道停止 JVM。

这张票：https://issues.apache.org/jira/browse/CAMEL-10596 类似于能够在 X 秒后自动停止、消息或空闲 X 时间。所以它会在 Camel 2.19 以后开箱即用。