java - 如何根据 Camel Exchange 的起源地进行不同的处理？

Question

我有一个具有多个入口点(servlet 和 direct)的路由。当通过 servlet 激活时，它需要执行某些工作。这项工作必须针对 servlet 请求完成(即使存在不良行为者)。如果是直接交换，则不得执行此工作。这是代码示例:

// In a Route Builder somewhere.
from("servlet:///myService").inOut("direct:myService");
from("direct:myService").process(new ConditionalProcessor());

// Implementation of processor above.
public class ConditionalProcessor implements Processor {

    @Override
    public void process(Exchange exchange) throws Exception {
        if(comesFromServlet(exchange)){
            // Logic for Servlet.
        } else {
            // Logic for direct and other.
        }
    }

    /**
     * Must return true if the exchange started as a request to the servlet.
     * Otherwise must return false.
     * 
     * @param exchange
     * @return
     */
    public boolean comesFromServlet(Exchange exchange){
        // What goes here?
    }

}

Answer 1

Exchange 上还有一个 API，可以告诉您它是从哪个端点创建的。 http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/Exchange.html#getFromEndpoint ()

exchange.getFromEndpoint().getEndp

另一种方法是，如果您为路线分配 ID，您也可以获得此信息

String fromRoute = exchange.getFromRouteId();

您可以使用 .routeId("myRouteId") 为路由分配 id

from("servlet:///myService").routeId("myRouteId")