Camel Content Based Routing

Question

Ich bin neu auf Kamel, ich möchte eine Kamelroute so schreiben, dass, wenn die obere Bean-Methode "Hi" zurückgibt, ich eine andere Route aufrufen muss. Aber das passiert nicht im untenstehenden Code. Bitte lassen Sie mich die Lösung wissen.

Hier ist mein Code:

<?xml version="1.0" encoding="UTF-8"?> 

<beans xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" 
    xmlns:jaxrs="http://cxf.apache.org/jaxrs" 
    xsi:schemaLocation=" 
     http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
     http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd 
     http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd 
     http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> 

<camelContext xmlns="http://camel.apache.org/schema/spring"> 
    <route id="firstRoute"> 
     <from uri="activemq:queue:test.queue" /> 
     <doTry> 
      <to uri="bean:myBean?method=appendCamel(1,hell)" /> 
       <log message="TEST LOG" /> 
      <when> 
       <xpath>${in.body} = 'hi'</xpath> 
       <to uri="stream:out" /> 
      </when> 
      <doCatch> 
       <exception>java.lang.Exception</exception> 
      </doCatch> 
     </doTry> 
     <to uri="stream:out" /> 
     <to uri="bean:myBean?method=appendCamel2(34)" /> 
     <to uri="stream:out" /> 
     <to uri="direct:nextRoute" /> 
    </route> 

    <route> 
     <from uri="direct:nextRoute" /> 
     <to uri="stream:out" /> 
    </route> 
</camelContext> 
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    <property name="brokerURL" value="vm://localhost?broker.persistent=false" /> 
</bean> 
<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent"> 
    <property name="connectionFactory" ref="connectionFactory" /> 
</bean> 

<bean id="myBean" class="Camel.CamelHelloWorldSid.MyBean" /> 

Answer 1

<camelContext xmlns="http://camel.apache.org/schema/spring"> 
    <route id="firstRoute"> 
     <from uri="activemq:queue:test.queue" /> 
     <doTry> 
      <to uri="bean:myBean?method=appendCamel(1,hell)" /> 
       <log message="TEST LOG" /> 
      <when> 
       <simple>${in.body} == 'hi'</simple> 
       <to uri="direct:nextRoute" /> 
      </when> 
      <doCatch> 
       <exception>java.lang.Exception</exception> 
      </doCatch> 
     </doTry> 
     <to uri="stream:out" /> 
     <to uri="bean:myBean?method=appendCamel2(34)" /> 
     <to uri="stream:out" /> 
     <to uri="direct:nextRoute" /> 
    </route> 

    <route> 
     <from uri="direct:nextRoute" /> 
     <to uri="stream:out" /> 
    </route> 
</camelContext> 

Answer 2

Sie sollten den Filter EIP verwenden: http://camel.apache.org/message-filter.html

<filter> 
    <simple>${in.body} == 'hi'</simple> 
    <to uri="direct:nextRoute" /> 
</filter> 

Wenn Sie mehr als ein Prädikat benötigen, dann müssen Sie verwenden der inhaltsbasierte Router: http://camel.apache.org/content-based-router.html (das ist wie wenn .. elseif ... elseif ... sonst in Java)