2017-05-08 1 views
0

これは私のシナリオです。私は現在、キューからActiveMQメッセージを処理するためにJavaアプリケーションに転送するために現在キャメルを使用している既存の処理アプリケーションを持っています。通常、異なるノードで実行されているアプリケーションの複数のインスタンスがあります。Apache Camelの条件付きルーティングを判断するJava呼び出しの作成

メッセージをアプリインスタンスにルーティングできるのは、そのインスタンスがそれを処理する能力を持っている場合だけです。 App Bean自体は、その容量状態を認識しています。メソッド "testCapacity"は、使用可能な容量を示すブール値を返します。

"いつ"条件付きの決定ポイントとしてBean自体を呼び出す方法を見つけようとする限り、私は検索しました。

これも可能ですか、可能であればどのように達成できますか?

<route> 
    <from uri="activemq:queue:myQueue" /> 
    <when> 
     <xpath>idontknowwhattoputhere("bean:javaBean?method=testCapacity")</xpath> 
     <to uri="bean:javaBean?method=doThings" /> 
    </when> 
</route> 
+1

完全に働いた豆言語http://camel.apache.org/bean-language.html –

答えて

3
<route> 
    <from uri="activemq:queue:myQueue" /> 
    <when> 
     <simple>${bean:javaBean?method=testCapacity}</simple> 
     <to uri="bean:javaBean?method=doThings" /> 
    </when> 
</route> 
+0

を掘り下げます! – Richard

関連する問題