問題タブ [apache-camel]

スプリング注入エンドポイントの例は次のとおりです。

別のサーバーの特定のポートに接続するようにクライアント モード エンドポイントを設定するにはどうすればよいですか?

インバウンド接続をリッスンするようにエンドポイントを構成するにはどうすればよいですか? (この例は、説明的な ID で示されるようにリスナーのようですが、なぜですか?)

注: 私は実際には HL7 プロトコルまたはコーデックを使用していません。独自のプロトコル コーデック用に独自に開発する予定です。

TCP から TCP へのルートを示す簡単なデモを ActiveMQ で開始しようとしています。activemq.xml 構成ファイルのキャメル コンテキストでエンドポイントとルートをコーディングしています。

なぜこれがうまくいかないのですか？

AMQ サーバーがリッスン ポートを開いていないようです。

編集: ここでの目的は、単純なデモンストレーションとして、2 つの telnet ターミナル (A と B) を使用して ActiveMQ に接続し、メッセージ キュー サーバーを介して一方から他方へメッセージをルーティングできるようにすることです。後で、コンテンツに基づいてフィルタリングまたはルーティングを試みる場合があります。

activemq と min の簡単なデモをセットアップしようとしています。activemq.xml ファイルの camelContext を編集して、2 つの mina tcp ソケット、2 つのキュー、およびルートなどを含めました。

リスナーA -> qA -> リスナーB リスナーB -
> qB -> リスナーA

その目的は、2 つの telnet セッション間で双方向のパス スルーを行うことです。後で、フィルター処理、トピックへのルーティング、各リスナーの独自のコーデックなどの高度な機能を追加します。

ここに私のキャメルコンテキストがあります:

activemq を開始すると、例外が発生します。

org.apache.camel.NoSuchEndpointException: 次のエンドポイントが見つかりませんでした: mina:tcp://localhost:42000?textline=true

ミナビーンを明示的に追加する必要がありますか? もしそうなら、どこで、どのように？

RouteBuilder を介して Camel コンテキストでルーティングを使用する場合、実際の違いは何ですか:

1) (A).to(B).to(C);

2) (A).から(B)へ; (B)から(C)へ

Camel Example "camel-example-spring-jms" ( http://activemq.apache.org/camel/tutorial-jmsremoting.htmlでも) を実行しようとしています。ただし、「org.apache.camel.spring.Main」クラスを使用して Camel を起動しようとすると、次のエラーが表示されます。

「構成の問題: XML スキーマ名前空間の Spring NamespaceHandler が見つかりません [ http://activemq.apache.org/schema/core]」

[注: Maven コマンド "mvn exec:java -PCamelServer" を使用すると、例を問題なく実行できます]

誰かがこれを引き起こしている可能性のあるものを理解するのを手伝ってもらえますか. 潜在的な解決のヒントも害にはなりません:)

++++++ エラースタック ++++++

++++++

私は特定のシナリオを念頭に置いたActiveMQ/Camel noobです。まず、それが可能かどうか、次に誰かが少し指示を与える可能性があるかどうか疑問に思います。

基本的に、キューから動的スロットリングを実行する必要があります。IEは、特定のメッセージグループがキューから消費される速度を実行時に設定する機能です。

たとえば、1秒あたり10で消費されるメッセージのグループ、1秒あたり1で消費される別のグループなどを追加する場合があります。

キャメルでのルートの設定やキューへのメッセージのグループ化などの基本は知っていますが、ドキュメントからこれを理解することはできません。

非同期リクエストに Apache Camel を使用するのは理にかなっていますか? または、JMS サーバーを使用して単純な MoM を使用する必要があります。必要なエンタープライズ統合パターンはありません。

どんな助けでも役に立ちます。

Grails ドメイン クラスを介してアクセスされる特定のデータベース レコードに基づいて入力/構成するキャメル ルート ファイルがあります。ただし、MyRoute.groovy からドメイン クラス (またはスプリング コンテキスト内のもの) にアクセスできないようです。それを可能にする方法についてのアイデアはありますか？

Grails: Bootstrap コードの destory クロージャーでのスプリング Bean へのアクセスで推奨事項を試しましたか? しかし、それはうまくいかないようです。

私は次のようにJavaDSLで書かれたキャメルルート定義を持っています：

これは、メッセージフローを1秒あたり200メッセージに制限するThrottlerを使用して2つのエンドポイントを接続します。

実行時にmaximumRequestCount/secondを変更する方法を探しています。だから私はどういうわけか呼び出されたThrottlerインスタンスに到達し、プロパティを変更する必要があります。

どうすればThrottlerにアクセスできますか？