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

3 周，4 日 Questions & Answers 1360

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

是否有任何方法可以在不使用JavaDSL指定线程睡眠时间的情况下运行camel

示例代码：

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();
        }

    }

}

Python中文网

有 Java 编程相关的问题?

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

共 (1) 个答案

# 1 楼答案