問題タブ [apache-camel]

Spring と NMS を使用して、.NET で ActiveMQ と Camel (ブローカーで実行) を使用しようとしています。一般に、これらのコンポーネントは見事に機能します。送受信用のキャメルルートと、これを処理する.NETのコードがあります-魅力のように機能します。

私が解決しようとしている問題は、要求と応答の統合パターンに関するものです。Camel はこれをサポートしており、設定に次のルートがあります。

理論的には、Camel はそのようなルートで NMSReplyTo と CorrelationID を設定することになっているため、返信はどこに戻るべきかを認識します。

この非常に役立つ記事に従って、.NET で物事を結び付ける方法を理解しました。この記事では、Camel を使用していないため、コードは返信の場所を明示的に設定します。

私の質問は、Camel ルートをどのように活用するかということです。そのため、基本的にコードで複製する必要はありません (構成ベースの統合パターンの目的を無効にすることになります)。コードで NMSReplyTo と CorrelationID を削除しようとしましたが、返信が送信者に返されません。Camel ルートがアプリケーションによって「内部化」されていないようです。

考え？提案？

ありがとう、チェット

イベント ドリブン アーキテクチャ (EDA) を使用して大まかなビジネス サービスの一部を統合することを検討しており、これらのサービスのサーバー側 (REST) は Java と .NET (C#) の両方で実装されています。私たちは当初、RabbitMQ (および AMQP プロトコル) をニュートラルでオープンな手段 (これら 2 つの言語での優れたクライアント サポート) として使用することを考えていましたが、Java と CLR と共に別のランタイム (Erlang) をサポートする必要があることを意味します。また、AMQP プロトコルの Java ブローカー実装を備えている Apache qPid も検討しています。これにより、その懸念が解消される可能性があります。

ActiveMQ の上でよりリッチな Apache Camel ESB を使用して Java と .NET サービスを Pub-Sub EDA 方式で統合しようとした経験のある人はいますか? これを通るルートに関して、他に考えられる提案を見逃していませんか?

ありがとう

ベテランの Spring ユーザーとして、私は Spring Integration がいくつかの (JMS) メッセージング機能を必要とする最近のプロジェクトで最も理にかなっているだろうと想定していました (詳細)。Spring Integration を数日使用した後でも、リクエスト/レスポンス (異なる JMS キューでリッスンする) 通信を行うために構成する必要があるチャネルの量を考えると、多くの構成オーバーヘッドのように感じます。

したがって、Camel が Spring Integration とどのように異なるかについての背景情報を探していましたが、そこにある情報はかなり予備のようです。

• http://java.dzone.com/articles/spring-integration-and-apache (2009 年 12 月以降、Spring Integration と Camel での実際の統合シナリオの実装の非常に中立的な比較)
• http://hillert.blogspot.com/2009/10/apache-camel-alternatives.html (Camel と他のソリューションの比較、2009 年 10 月)
• http://raibledesigns.com/rd/entry/taking_apache_camel_for_a (Matt Raible、2008 年 10 月)

質問: あるスタックを他のスタックよりも使用して、どのような経験をしましたか? Spring Integration にサポートがない場合、どのシナリオで Camel をお勧めしますか? それぞれの長所と短所はどこに見られますか? 実際のプロジェクトからのアドバイスは大歓迎です。

さて、ActiveMQ ベースのチャット アプリケーションを構築しているとしましょう。とてもシンプルです。QUEUE.IN1と 1しかありませんTOPIC.OUT。QUEUE.INすべてのメッセージは、 からにすぐにルーティングされTOPIC.OUTます。クライアントは、 に対してチャット メッセージを作成しQUEUE.IN、 から消費してTOPIC.OUTいます。それで全部です。

今、私はそれをクラスター化したいと思います。複雑なものは必要ありません。他のいくつかの同一のノードを実行するだけです(A..N)。基本的に、Aノードにサブスクライブされたクライアントは、メッセージを に送信しますA.QUEUE.IN。このメッセージは、他のすべてのノードに表示される必要があります(A..N).TOPIC.OUT。TOPIC.OUTこれは、すべてのメッセージを他のノードに再ルーティングする単純なキャメル ルートで簡単に実行できますが、そうするための優れた ActiveMQ ネイティブの方法はありますか? 複数の AMQ インスタンス間で共有されるキュー/トピックが好きですか?

Spring Bean をセットアップしたいと思います (インターフェイスまたは Bean クラスを介して)。ルートを「開始」するために呼び出すことができます。

この単純な例では、コードから sayHello("world") を呼び出すときに、sayHello メソッドの戻り値をファイルに書き込むエンドポイントにルーティングしたいと考えています。

これが可能かどうか、またはこれを行う方法を知っている人はいますか? CXF を介して同じインターフェイスを公開し、これを機能させることができることはわかっていますが、本当にメソッドを呼び出したいだけで、jms メッセージを送信したり、Web サービスを呼び出したりする手間を省きたいのです。

キャメルプロキシを使用して、ルートの開始点としてインターフェイスを公開しています。BeanInvocationオブジェクトをメッセージ本文として使用します。インターフェイスに渡された引数に基づいてメッセージ本文とヘッダーを設定するにはどうすればよいですか？

ボディ（firstName + "" + lastName）を作成したいのですが。また、一方の引数をメッセージのヘッダーとして設定し、もう一方の引数を本文として設定する方法も知りたいです。

CXFRSエンドポイントを定義するルートがあります。インバウンドリクエストからカスタムHTTPヘッダー値を取得する必要があります...

これがクライアントリクエストをシミュレートするためのユニットテストコードです...

問題は、カスタムヘッダー「myHeader」が私のルートから利用できないことです。それに到達する別の方法はありますか？

camel-cxfのソースコードを見ると、デフォルトのヘッダー戦略/バインディングロジックは事前定義されたHTTPヘッダーのみを設定していることがわかります。他のヘッダーも渡されない理由はありますか？

いずれにせよ、この動作をオーバーライドするための最良のアプローチは何ですか？

ありがとう

Java で記述された単純なルートがあり、jar ファイルを activemq/lib にデプロイし、activeMQ.xml を更新して、パッケージの can 要素を介してルートを探します。

しかし、ルートは Web 管理コンソールに表示されません...他にどのような手順が関係しているのか疑問に思っています...

}

次に、activemq/conf/activemq.xml http://activemq.apache.org/camel/schema/spring"> com.apps.mdt.routes の下に次の構成があります。

これは、camel のバージョンを 1.6 から 2.4 に変更したときに発生する問題です。1.6 でサポートされていないメソッド userOriginaLmessage を使用したかったのです。したがって、camel 2.4 バージョンの使用を開始します。コードがコンパイルされています。しかし、Fuse ESB 環境にデプロイすると以下のエラーが発生します。

クラス パス リソース [camel-route.xml] から XML ドキュメントを解析中に予期しない例外が発生しました。ネストされた例外は java.lang.VerifyError:

これについて私を助けてもらえますか？何が問題になる可能性があります。

助けてくれてありがとう。

camel がリモート ホストに接続するには、既にホストのフィンガープリントを確認し、それを .ssh/known_hosts のように known_hosts ファイルに記録する必要があります。

完全な URL を含めるには小さすぎるデータベースのフィールドからこのファイルの設定を取得します... .ssh ファイルを sftp エンドポイントが探しているデフォルトの場所にシンボリック リンクできれば、その必要はありません。 URLで指定すると、URLがカラムに収まり、人生が美しくなります。

問題は、このファイルがどこにあるとキャメルが期待しているのかということです。