apache-camel

    8

    1答えて

    Apache Camelのルートにある "プロモーションの単位"とは何ですか?意味、実際にルーティングされているオブジェクトは何ですか?? Exchange? I がRouteが1+ Processorエンドポイントからなり、(Messageを含む)Exchangeが実際にすべてのエンドポイント間でルーティングされる何だったということと思ったので。私が尋ねる しかし、Exchangeインバウンド及

    7

    1答えて

    私はSpringを学び、その動作を理解しようとしています。私はSpringとCamelを設定する際にいくつかのチュートリアルに従い、デフォルトの設定を使って作業していました。 できるだけ多くの設定XMLファイルをJavaクラスに変換しようとしています。これまでは、Javaクラス(SpringRouteBuilderの拡張とconfigure()の実装)とすべてのBeanをバネ設定ファイル(Bean

    8

    1答えて

    私はCamelから出発していますが、テストを書く上で問題があります。私のユースケースは、cfx proxy exampleとまったく同じです。私は "RealWebservice"は必要ではないことを除いて。今私は、アノテーションのアプローチを使用して、ユニットテスト(ない例に含まれているとして、統合テスト)を書き込むしようとしている:は @RunWith(CamelSpringJUnit4Cla

    7

    1答えて

    私は _ from(A) _ .split()... _ .choice() //Choice 1 _ .when(predicate) _ .process() _ .choice() // Choice 2 _ .when(x) _ .to(X) _ .otherwise() _ .to(Y) _ .end() // to terminate inner

    6

    1答えて

    私はトークナイザを使用して行にファイルを分割しています: .split().tokenize("\n", 1) しかし、私が処理する必要があるファイルのいくつかは、ヘッダが含まれていますラインは、通常のラインとは異なる方法で処理する必要があります。最初の行を読み、処理し、残りの行を分割する簡単な方法はありますか?

    6

    2答えて

    Apache Camelは、Transform EIP、カスタムDataFormatsのコンセプト、カスタムタイプコンバーターの許容量など、データ変換を実行するいくつかの方法を提供しています。 私は、キャメルルートの内部から非常に複雑な変換を行う必要がある状況があります。私は自分の形コンバータ、私自身のデータフォーマットを実装すること、または私はorg.apache.camel.Expressio

    7

    1答えて

    キャメルやFtpクライアントの問題があるかどうかはわかりませんが、私は永遠に吊るされたようなラクダルートを手に入れました。 ftpコンポーネントのsoTimeoutは60000に設定されています。コンポーネントの バージョン: ラクダのftp:2.9.0 コモンズネット:(2.2) スレッドダンプ: "Camel (some-ftp-route) thread #57 - ftp://[email

    17

    1答えて

    WAS ND 8.0クラスタでApache Camel(またはSpring Integration)を使用してコンポーネントを実行する必要があります。彼らは両方とも起動時にいくつかのスレッドを実行し、正常にシャットダウン時にそれらを停止します。 WAS管理スレッドプールを提供するのに問題はありません。しかし、そのスレッドは、の単一のクラスタノードで同時に実行する必要があります。さらに、それは、高性

    10

    3答えて

    ホープこれはばかげて聞こえませんが、どうすればいいですか?メッセージを破棄します in Camel 目的で? これまで、私はそれらをLog-Componentに送っていましたが、私は引き出しをログに記録したくもありませんでした。 Camelには、/dev/null Endpointがありますか?

    6

    1答えて

    私は、青写真のXML Camelのルート内でメッセージの有効期限を設定しようとしています。有効期限として設定したい値は、メッセージ本文(protobuf)内に保持されます。ここで は私のコードです: - <setHeader headerName="AMQ_SCHEDULED_DELAY"> <method bean="NotificationScheduler" method="pos