問題タブ [apache-camel]

spring.xmlファイルからの抜粋と取得したスタックトレースを投稿しました。

これはこの例外をスローします：

誰かが問題がどこにあるか助けてくれますか？

このルートを使用しようとしています：from（ "activemq：profiles"）。aggregate（header（ "cheese"））。batchSize（30）.bean（ProfilesQueueService、 "saveContacts"）

失敗する：

メソッドのシグネチャなし：org.apache.camel.model.RouteType.aggregate（）は引数タイプに適用可能：（org.apache.camel.builder.ValueBuilder）値：[header（cheese）]

apachecamel1.6.1を使用してRouteTypes.javaを確認しました。実際、aggregate（）メソッドはありません。ただし、このドキュメントには、機能する必要があると記載されています：http: //camel.apache.org/aggregator.html

私が間違っているのは何ですか？

あるディレクトリから別のディレクトリにファイルをコピーする単純なApache Camelの例を実行したいと思います。

Apache Camel 2.0.0 を使用してこの例を実行すると、プログラムは直後に終了context.start();し、何もしません。Thread.sleep(30000);の開始後に追加するCamelContextと、バックグラウンド スレッドが動作し、ファイルがソース ディレクトリから宛先ディレクトリに 30 秒間コピーされます。

ただし、Apache Camel 1.6.2 を使用して同じコードを実行すると、start()メソッドは自動的にブロックされるため、ファイルをコピーするためにメイン スレッドをスリープ状態にする必要はありません。この動作が Camel 1.x から 2.x に変更されたというヒントは見つかりませんでした。これは本当に意図した動作ですか? Camel 2.0.0 で start() メソッドが実行をブロックすることは可能ですか?

ありがとう

Servicemix で Camel 2.1 SU を実行しようとしています。私が理解しているように、Servicemix 3 で Camel 2 を実行する方法はなく、FUSE Servicemix 4.0.0.1 で実行しようとしています。

Maven でプロジェクトを開始すると、mvn jbi:servicemix次のエラーが表示されます。

これは、 mycamel-context.xmlが Camel 1.x によって解析されたことを意味します

SA/SU で提供されているバージョンの Camel を使用する方法はありますか? はい、Servicemix をダウンロードして、既存の Camel 1.x を削除し、自分のバージョンをそこに配置できることはわかっていますが、そのようなハッキングはしたくありません :(mvn jbi:servicemixコマンドのみを使用してこれを実行する必要があります

このプロジェクトのすべてのソース (poms など) は、http://github.com/splix/smx-currency-rates/tree/skeleton で確認できます。

Apache-Camel と ActiveMQ を使用してシステムを構築するための一般的/推奨される方法は何ですか? 高可用性を実現するにはどうすればよいですか? Camel はどのコンテナで実行する必要がありますか?

埋め込み Camel ルーティングで、リモート JMS キューへの耐久性のあるコンシューマーがあります。マスター/スレーブ構成でこの種のルーティングを行うことは可能ですか? 現在、Camel ルートは、実際のフェイルオーバーが発生したときではなく、スレーブ ActiveMQ が開始されたときにすでに開始およびアクティブ化されているようです。

これにより、スレーブ インスタンスは、マスターにも送信される同じメッセージを受信するようになり、これにより、フェイルオーバー時に重複したメッセージがキューに到着します。

ActiveMQ 5.3 と Apache Camel 2.1 を使用しています。

私はその概念に頭を悩ませています。

独自の形式の受信メッセージを tcp ポートでリッスンするエンドポイントを実装しようとしています。これにより、メッセージが変換され、キャメルが転送とルーティングを引き継ぎます。

Producer が にメッセージを送信し、がそのエンドポイントからメッセージを受信するEndpointことを正しく理解できましたか?Consumer

インターフェイスを調べたとき、特にコンシューマー側で、これらのオブジェクト間のメッセージ フローを理解できませんでした。Consumer定義start()とstop()メソッドのみ...

エンドポイントとプロデューサー オブジェクトでCamel呼び出されるスケルトン実装でテストを設定する場合。その後、関連するコンシューマまたはプロセッサに何もせずに戻ってきました。createProducer()process()

誰かが私を正しい方向に向けることができますか?

ドキュメンテーション/チュートリアルを見つけたり、依存関係の概要を取得したりするのに苦労しています。

無限のコンパイル、実行、検索、繰り返しルーチンであるため、例を機能させるのに苦労しています。専門家の圧力に屈しない人のために、誰かがいくつかの情報リソースを推奨できますか?:)

GrailsアプリケーションでCamelコンテキストを定義しようとしています。

resource.groovy：

次を含むスタックトレースが生成されます。

2010-02-03 13：24：42,209[メイン]エラーspring.GrailsRuntimeConfigurator-[RuntimeConfiguration]resources.groovyからBeanをロードできませんorg.codehaus.groovy.runtime.InvokerInvocationException：java.lang.NoClassDefFoundError：org / apache / camel / spi / ManagementStrategy

奇妙なことに、ManagementStrategyはlib/camel-core-2.1.0.jarにあります。私はSpringもCamelもあまりよく知らないので、どんな提案も歓迎します。これはクラスローダーの問題である可能性がありますか？

ServiceMix 3.3.1 / Camel 2.1 /AMQ5.3アプリケーションをクラスタリングするためのオプションを決定しようとしています。大量のメッセージ処理を実行していますが、高可用性と水平方向のスケーラビリティを実現するためにクラスター化する必要があります。

これが基本的に私のアプリケーションが行うことです...HTTP->QUEUE-> PROCESS-> DATABASE-> TOPIC

from（ "jetty： http: //0.0.0.0/inbound "）.to（ "activemq：inboundQueue"）;

from（ "activemq：inboundQueue？maxConcurrentConsumers = 50"）.process（decode（））.process（transform（））.process（validate（））.process（saveToDatabase（））.to（ "activemq：topic：ouboundTopic" ）;

したがって、ServiceMixとAcitveMQのクラスタリングページをすべて読みましたが、どちらに進むべきかまだわかりません。

HAにマスター/スレーブセットアップを使用できることは知っていますが、それはスケーラビリティには役立ちません。

ブローカーのネットワークについて読みましたが、これがどのように適用されるかわかりません。たとえば、クラスター内の複数のノードに同一のCamelルートをデプロイした場合、それらはどのように正確に「相互作用」しますか？HTTPプロデューサーを1つのノード（NodeA）に向けると、どのメッセージがNodeBに送信されますか？キュー/トピックはノードA/B間で共有されますか？共有される場合、メッセージは分割または複製されますか？また、外部クライアントはどのようにして私の「outboundTopic」を正確にサブスクライブしますか（そしてすべてのメッセージなどを取得しますか）？

あるいは、複数のServiceMixインスタンス間でブローカーを共有するだけでよいと考えていました。管理するキュー/トピックのセットが1つしかないという点で、これはよりクリーンであり、インスタンスを追加することで拡張できます。しかし、今では単一のブローカーのスケーラビリティに制限されており、単一障害点に戻っています...

誰かが私にとってのトレードオフを明確にすることができれば...私はそれをいただければ幸いです。