ApacheCamel轮询restendpoint

Question

我有一个restendpoint示例。org，返回表单的json响应

{
  "response" : "pending" 
}

我的路线是这样的

from("http://sample.org")
.marshal(xmlFormatConverterUtil.getxmlJsonDataFormat())  //To convert into json as I receive data in xml format which needs to be converted to json

我读过关于轮询消费者的内容，但找不到如何继续轮询endpoint的示例，直到它返回“success”响应。

是否应该使用轮询消费者？如果是这样的话，可以举一个与我的案例相关的例子。用于轮询restendpoint的任何其他资源都非常有用。

Answer 1

我也遇到了类似的问题，最后编写了一个自定义endpoint进行轮询。

它充当生产者并轮询指定的uri，直到满足指定的谓词或轮询达到最大尝试次数。

from("direct:start")
  .to("poll:http://example.com/status?maxRetries=3&successPredicate=#statusSuccess")

轮询endpoint使用一个简单的处理器，该处理器使用轮询消费者进行轮询。

public class PollProcessor implements Processor {

    private final String uri;
    private final long requestTimeoutMs;
    private final long period;
    private final int maxTries;
    private final Predicate<Exchange> successPredicate;

    public PollProcessor(String uri, long requestTimeoutMs, long period, int maxTries, Predicate<Exchange> successPredicate) {
        Preconditions.checkArgument(maxTries > 0);
        Preconditions.checkArgument(period >= 0);
        Preconditions.checkNotNull(successPredicate);

        this.uri = uri;
        this.requestTimeoutMs = requestTimeoutMs;
        this.period = period;
        this.maxTries = maxTries;
        this.successPredicate = successPredicate;
    }

    @Override
    public void process(Exchange exchange) throws Exception {
        PollingConsumer consumer = exchange.getContext().getEndpoint(uri).createPollingConsumer();

        for (int tryNumber = 1; tryNumber <= maxTries; ++tryNumber) {
            Exchange pollExchange = consumer.receive(requestTimeoutMs);
            if (successPredicate.test(pollExchange)) {
                exchange.setOut(pollExchange.getOut());
                exchange.setException(pollExchange.getException());
                return;
            }

            log.warn("Polling {} failed try number {}, waiting {} ms for next try...", uri, tryNumber);
            Thread.sleep(period);
        }

        throw new RuntimeException("Polling failed maximum allowed number of tries [" + maxTries + "], see log for details.");
    }
}

Answer 2

您需要从计时器开始，然后调用restendpoint。然后，您可以检查结果，如果结果正确，则使用controlbus停止路线。过滤器可用于检查其是否挂起，然后停止继续路由，然后下一个计时器将重试。

沿着这条伪路线的一些东西

from timer
  to http
  marshal
  filter (if pending)
     stop 
  end
  to something with positive response
  to controlbus stop route

您可以在以下网址找到更多详细信息：

• http://camel.apache.org/timer
• http://camel.apache.org/controlbus
• http://camel.apache.org/how-can-i-stop-a-route-from-a-route.html
• http://camel.apache.org/message-filter.html