問題タブ [apache-camel]

SericeMix の起動中にバンドルがロードされるとすぐに、ServiceA が ServiceB を呼び出すことを試みています。Service2 には activemq エンドポイントがあり、その特定のサービスのメソッドを呼び出す必要があります。私はそのメソッドで ServiceA のメソッドを自動トリガーするのに役立つ bean タグの spring init-method 属性を試しました。私は serviceB のメソッドを呼び出しています。エンドポイントで No Consumer のような例外が発生しています。Service1 が起動するとすぐに、@Produce アノテーションの activemq エンドポイントを使用して初期化する必要がある service2 のインスタンスを取得していないと仮定します。他の通常のシナリオでは、同じサービスが正常に機能します。

例外: 原因: org.apache.camel.CamelExchangeException: エンドポイントで使用可能なコンシューマーがありません: Endpoint[direct://ServiceB]。Exchange[Message: BeanInvocation public java.lang.String java.lang.Object.toString() with null]] at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:46) at org.apache. camel.component.bean.CamelInvocationHandler.invoke(CamelInvocationHandler.java:64) ... 35 もっと見る

参考までにコード ブロックをコピーして貼り付けます。

または、この要件を達成する必要がある場合、他の方法はありますか? servicemix の起動中に、サービスを自動的にロードする (他のサービスを消費する) ことができます。

camel からリモート ブローカーにリクエスト/リプライ メッセージを送信しようとしていますが、タイムアウトします。以下の構成を参照してください。

なぜこれが起こるのですか？リモートブローカーでは、コンシューマーの数を指定していませんが、コンシューマーの数が常に 1 を超えていることに気付きました。また、replyTo の宛先を削除しても、名前はリモート ブローカーに表示され続けます。

Pls、activemq をデバッグして、誰がキューからメッセージを取り出しているかを確認できるツールはありますか?

次のように、cxfコンポーネントを使用してラクダからWebサービスを利用しようとしています。

このsendMessageメソッドには応答がないため、inOnlyではなくto（代わりに試してみると同じ問題が発生しtoます）。問題は、明らかにラクダがまだ応答を期待していて、応答を待っている間にルートがハングすることです。十分に長く試してみると、やがてタイムアウトになると思います。

明確にするために、私はテストメソッドを実行しています：

そして、最初の呼び出し（つまり、メッセージがサーバーに到着する）の効果が表示されていますが、2番目の呼び出しは表示されておらず、メソッドの実行が終了していません（ここでも、ある時点でタイムアウトになると想定しています） ...もしそうなら、タイムアウトはかなり長いです：私はこれを書き始めたときにテストを実行しました、そしてそれはまだ実行中です）。

私は何かが足りないのですか？バグですか？応答のないWebサービスメソッドを使用するのは悪い習慣ですか？

ちなみに、応答のあるメソッドをテストする場合は問題なく動作します。

キャメルルートを介して別のJBIコンポーネントを呼び出すJBIコンポーネントを開発しています。2番目のコンポーネントは、ハングアップすることがあるある種の長い操作を実行します。タイムアウト（たとえば5秒）で制限されるようにCamelルートを構成したいと思います。どういうわけか非同期呼び出しとして動作するはずです...それは可能ですか？

Grails ルーティング プラグインを使用すると、コンパイル時に Apache Camel ルートを簡単に作成できます。実行時に新しいルートを作成する方法はありますか?

この正規表現ステートメントが私が望むことを実行することを確認する必要があります。

次のjson文字列が与えられます

次の正規表現を確認する必要があります

文字列Provider"："に続く単語を常に返します

この場合、文字列Provider "："に続く単語はWebHookですが、任意の単語にすることができます。私はこの単語を制御できるので、ASCII以外の文字が含まれることはありません。

この式は、Java正規表現エンジンを使用するApacheCamelで使用します。

誰かが私の戦略の落とし穴を見つけることができますか？

私ができるようにしたいのは、次のとおりです。

from(...)
.replyWith()
.from(...)
.end()

私のプロデューサーへの応答が別のエンドポイントの消費から取得されるように、例はキューの REST エンドポイントのようなものになります。

CamelContext インスタンスからエンドポイントを取得し、コンテンツを手動で取得して Exchange に設定することなく、上記のようなことを実行できるキャメルの慣用的な方法はありますか?

レジストリは、データベーステーブルのインデックスやライブラリのカード目録など、アイテムを見つけるためのポインタを含むアイテムのリストです。

私が間違っている場合は訂正してください。この定義から、ラクダのアプリケーションレジストリに期待するのは、クライアントアプリケーションが（クライアントプロトコルに応じて）ルックアップを実行し、メタデータに基づいて特定のサービスを選択し、それを次のように使用できる場所です。定義されています。

ApacheCamelにこれに近いものがあるかどうか疑問に思います。私が見たサービスレジストリの記事/実装のほとんどは、SOAPプロトコルのみを扱っているようです。

よろしく。

次のようなcamlejpaコンポーネントのクエリについて

Beanのラクダ交換からレコードのリストを取得するにはどうすればよいですか？List、Resultsetオブジェクトとしてキャストしようとしましたが、ClassCastExceptionが発生します。

この例では、Apache Camel と Apache CXF を使用しています。

http://camel.apache.org/better-jms-transport-for-cxf-webservice-using-apache-camel.data/cxfcamelexample.zip

JMS の代わりに AMQP を使用したいのですが、構成がわかりません。また、誰かが助けてくれる場合は QPID クライアントのバージョンを変更する必要があります。これは素晴らしいことです。