0

我正在使用一个程序使用 jms 和 apache camel 将消息发布到 activemq ..

public final class CamelJmsTofileExample {

    private CamelJmsTofileExample() {}

    public static void main(String args[]) throws Exception {
        CamelContext context = new DefaultCamelContext();
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
            "vm://localhost?broker.persistent=false");
        context.addComponent("test-jms",
            JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
        context.addRoutes(new RouteBuilder() {
            public void configure() {
                from("test-jms:queue:test.queue").to("file://test");
            }
        });
        ProducerTemplate template = context.createProducerTemplate();
        context.start();
        for (int i = 0; i < 100; i++) {
            template.sendBody("test-jms:queue:test.queue", "Test Message: " + i);
        }
        Thread.sleep(1000);
        context.stop();
    }
}

它正确放置了 10 条消息...但是问题是当将“i”的计数增加到 100,500 或者我无法在测试文件夹中找到这么多消息时...帮助我解决这个问题...谢谢提前..

4

1 回答 1

0

如果您将这么多消息发送到队列，那么您可能需要在线程睡眠中等待更长时间，然后才能停止 Camel 和应用程序。

例如，您需要给它更多时间来处理队列中的所有消息。

于 2014-03-21T09:47:40.910 回答