問題タブ [apache-camel]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-camel - Camelを使用した分散ActiveMQ
私はActiveMQとCamelを学習している最中であり、次のような動作をする小さなプロトタイプシステムを作成することを目標としています。
(出典:paulstovell.com)
Ordersシステムで注文が行われると、すべてのサブスクライバー(pub / subシステム)にメッセージが送信され、サブスクライバーは注文の処理に関与できます。Orders、Shipping、およびInvoicingアプリケーションには独自のActiveMQがインストールされているため、3つのシステムのいずれかがオフラインの場合でも、他のシステムは引き続き機能します。ActiveMQインストール間でのメッセージの移動は何かが処理します。
メッセージが同じActiveMQインスタンス上にある場合、ApacheCamelでメッセージをあるキューから別のキューにルート経由で移動するのは非常に簡単です。したがって、これはサブスクリプションキューを管理するために機能します。
次の課題は、あるActiveMQインスタンスから別のインスタンスにメッセージをプッシュすることです。これは、次に何を見るべきかわからない部分です。
- Camelは異なるActiveMQインストール間をルーティングできますか?(異なるマシン上にある場合、JMIエンドポイントURIがどうなるかわかりません)。
- ActiveMQにはストアアンドフォワード機能があることを理解しています。これは、注文と配送/請求の間でメッセージを移動するために使用するものですか?
- それとも、これはApache ServiceMixが解決することを意図しているものですか?
java - Apache Camel マルチパート HTTP 投稿 (ファイルのアップロード)
Apache Camel HTTP コンポーネントを使用してマルチパート ファイルのアップロードを行うにはどうすればよいですか?
apache-camel - ManagedPerformanceCounterの拡張
独自のパフォーマンスカウンターを追加しようとしましたが、このパフォーマンスカウンターをルートに使用できません。
ManagedPerformanceCounterの代わりにカスタムパフォーマンスカウンターを使用する方法を教えてもらえますか?
ありがとうございました。
grails - 実行時のJMSキューの作成
アプリユーザーがキューを作成/削除できるアプリケーションに取り組んでいます。また、あるキューから別のキューにメッセージを移動したり、メッセージを削除したり、フィルターに基づいてキュー内のメッセージを再配置したりすることもできます。
考えられる設計の1つは、キューにactivemqを使用し、Grailsと統合された他のさまざまな操作にApacheCamelを使用することです。しかし、ActiveMQが実行時に作成/削除キューを許可するかどうかはわかりません。
これは、そのようなシステムを実装するための良い選択でしょうか?
activemq - ActiveMqトピックを外部ブローカーにルーティングする
変換して外部ブローカーと共有したいActiveMqトピックがあります。現在、変換を実行する次のものがあります。
ただし、これはメッセージを現在のブローカーネットワークに送信するだけです。NewTopicメッセージを外部ブローカーにのみ渡したいのですが。<networkConnector ..>を使用して外部ブローカーに参加したくないのは、このトピックのみを外部ブローカーに送信し、他のトピックは送信しないためです。
メッセージを外部ブローカーにルーティングする簡単な方法はありますか?
どうもありがとう。
アップデート
上記の方法には、元のトピックのサブスクライバーがメッセージを受信しなくなるという欠点もあります。元のトピックを失わずに別の宛先にルーティングする方法はありますか?
java - Apache Camelを使用して、CXFエンドポイントを介して入ってくる逆シリアル化されたオブジェクトをアンマーシャリングするにはどうすればよいですか?
私は非常に単純なラクダのルートを持っています。これは、Webサービスとして公開されているCXFエンドポイントから始まります。次に、それをxmlに変換し、Beanのメソッドを呼び出します。
現在、Webサービスの呼び出し後にCXF固有のオブジェクトを取得しています。シリアル化されたオブジェクトをCXFメッセージリストから取り出して、今後使用するにはどうすればよいですか?
私のルート:
XMLシリアル化メッセージ:
XMLは次のようになると思います。
java - ActiveMQとCamel-ルーティングパスに依存関係を作成する方法
実装するメッセージルーティングがあります。これには、メッセージの内容に応じて異なるルートがあります。ルートの一部のストランドは他のストランドに依存しています。
たとえば、実行するTask_AとTask_Bを持つData_Aがあるとします。一方、Data_Bには、実行するTask_Bのみがあります。
ここで、各タスクには、コンシューマーによって提供されるキューがあります。
データに対してTask_Bが要求された場合に、Task_Bの後にのみTask_Aを実行する必要がある場合、そのような依存関係を設定するにはどうすればよいですか?
java - Java Messaging : ActiveMQ、Mule、ServiceMix、Camel の違い
ActiveMQ
Messaging は初めてで、 、Mule
、ServiceMix
およびの違いを知りたいCamel
これらの製品のそれぞれがどのように異なっているか知っている人はいますか?
前もって感謝します !
編集:また、これらのことを学ぶのに適した場所/リソースを知りたい.
apache-camel - DBクエリに基づいて複数のファイルを適切に生成する
次の質問があります。SQLクエリに基づいて多くのファイルを生成する必要があります。
たとえば、データベースから今日行われた注文のリストを取得し、注文ごとにファイルを生成し、後で各ファイルをftpに保存するとします。
理想的には、私は次のようになりたいです。入手方法がよくわかりません。
from(MyBean).to(Ftp)
問題と主な質問は、カスタムBeanによって複数のメッセージを生成する方法です(たとえば)。
この場合、分割するメッセージが1つだけではなく、多くのメッセージを生成して送信する必要があるため、スプリッターEIPが問題ないかどうかはわかりません。 http://camel.apache.org/splitter.html
誰かが以前にこの問題に遭遇したことを願っています。
タスクが1つのファイルだけを生成することである場合(すべてが非常に単純です)、Exchange.OutMessage(またはこのようなもの)に入力するだけです。しかし、複数のファイルについてはどうでしょうか。この状況をどのように管理するか、私は本当に理解できません。
PSこの質問がばかげているなら申し訳ありません。私はCamelの初心者です(クーペ週間だけそれを使って作業しています)。それは素晴らしいツールです。実はそういうわけで私は最善の方法で使いたいのです。
どうもありがとう。
spring - SpringコンテキストでBeanとして定義されたEndpointにEndpointパラメーターを渡す方法
私はラクダのFileendpointを次のように定義しました:
preMove、moveなどのいくつかのファイルパラメータを定義したい。変数hotfolderはJNDIから取得した文字列であり、影響はありません。プロパティを次のように定義すると
正しく解析されておらず、ファイルはname done/nameを取得します