Apache Camel routage conditionnel

J'ai un service qui a deux opérations.

RegisterUser
UpdateUser

J'ai un chameau déroute:

<camel:route id="myRoute">
    <camel:from uri="cxf:bean:myListenerEndpoint?dataFormat=POJO&amp;synchronous=true" />            
    <camel:bean ref="processor" method="processMessage"/>
    <camel:to uri="xslt:file:resources/service/2.0.0/UserRegistration.xsl"/>
    <camel:to uri="cxf:bean:myTargetEndpoint"/>
</camel:route>

Dans mon processeur bean, alors que j'ai spécifié:

RegisterUser registerUser = exchange.getIn().getBody(RegisterUser.class);

- Je obtenir le registre de l'utilisateur de l'objet. Tout fonctionne très bien.
Le problème est que je veux chameau de route de ma demande, sous certaines conditions, pour l'e.g:

Si l'opération de service est RegisterUser je veux router le message vers mon haricot et si l'opération de service est UpdateUser je veux router le message vers l'autre bean.

J'ai essayé d'utiliser le chameau xPath, mais il ne semble être au travail.

<camel:route id="myRoute">
    <camel:from uri="cxf:bean:myListenerEndpoint?dataFormat=POJO&amp;synchronous=true" />  
    <camel:choice>
        <camel:when>
            <camel:xpath>
                //RegisterUser
            </camel:xpath>
            <camel:bean ref="processor" method="processMessage"/>
            <camel:to uri="xslt:file:resources/service/2.0.0/UserRegistration.xsl"/>
        </camel:when>
    </camel:choice>                        
    <camel:to uri="cxf:bean:myTargetEndpoint"/>
</camel:route>

Je cherchais comment mettre en place chameau de route pour les différentes cibles, mais n'a pas trouvé quoi que ce soit. Peut-être que quelqu'un sait d'où pourrait être le problème?

OriginalL'auteur Paulius Matulionis | 2012-07-27

Les informations de l'opération requise sera dans l'en-tête du message.

L'en-tête vous êtes à la recherche pour l'un est appelé "operationName'

Voici donc un exemple :

<camelContext xmlns="http://camel.apache.org/schema/blueprint">
    <route id="example">
        <from uri="cxf:bean:myListenerEndpoint?dataFormat=POJO&amp;synchronous=true" />
        <log message="The expected operation is :: ${headers.operationName}" />
        <choice>
            <when>
                <simple>${headers.operationName} == 'RegisterUser'</simple>
                    <bean ref="processor" method="processMessage"/>
                <to uri="xslt:file:resources/service/2.0.0/UserRegistration.xsl"/>
            </when>
            <when>
                <simple>${headers.operationName} == 'UpdateUser'</simple>
                <!-- Do the update user logic here -->
                <bean ref="processor" method="updateUser" />
            </when>
        </choice>
    <to uri="cxf:bean:myTargetEndpoint"/>
    </route>
</camelContext>

(Note de l'exemple à l'aide d'apache bélier plan d'action - mais il sera identique pour le printemps, autre que l'espace de noms)

Cela fonctionne très bien pour moi. Exactement ce dont j'avais besoin. Merci!!!! 🙂

OriginalL'auteur AlanFoster

6

essayez d'utiliser chameau-simple expressions au lieu de xpath pour cette...
```
<when><simple>${body} is 'com.RegisterUser'</simple><to uri="..."/></when>
```
OriginalL'auteur Ben ODay

Printemps XML itinéraire
Dans mon cas, j'utilise entrant Jetée EP.
- Je vérifier parametr dans la requête.
Invole URL http://localhost:8080/srv?alg=1

    <choice id="_choice1">
    <when id="_when1">
        <simple>${in.header.alg} == '1'</simple>
        <log id="_log10" message="LOG ALG 1"/>
    </when>
    ...
    <otherwise id="_otherwise1">
        <setFaultBody id="_setFaultBody1">
            <constant>Return message about ERROR</constant>
            </setFaultBody>
    </otherwise>
</choice>

OriginalL'auteur Vladimir Azarov

Vous devez vous connecter pour publier un commentaire.