Apache Camel：轮询消费者

Question

我是Apache Camel的新手，我试图在一个简单的项目中理解和使用轮询消费者EIP，但我感到有点迷茫…谁能帮我解释一下，甚至用一个小的工作例子。

如有任何帮助，我们将不胜感激

Answer 1

对于大多数用例，只需在route...中的from()子句中定义使用者，即可创建使用者。

from("activemq:inbox").to(new MyProcessor());

但是，您也可以编写自己的POJO轮询使用者逻辑，以便对使用者逻辑进行更多的控制...只需使用计时器定期启动它，并调用receive()方法，如下所示：

from("timer://foo?period=5000").bean(MyBean, "processQueue");

public void processQueue() {
    while (true) {
        // receive the message from the queue, wait at most 3 sec
        String msg = consumer.receiveBody("activemq:inbox", 3000, String.class);
        if (msg == null) {
            // no more messages in queue
            break;
        }

        // do something with body
    }
}

更多详情请参阅文档：http://camel.apache.org/polling-consumer