apache-camelで嵐のボルトに接続するときに複数のセッションを作成する

Question

私はApacheの嵐に取り組んでおり、Apache-camelを使ってtibco-emsのトピックにメッセージを渡す予定ですtibco-ems接続ですが、転送されるメッセージの量が膨大なので、オーバーロードを避けるために、ボルトの各インスタンスはトピックとは別のセッションを持つ必要があります。個別のセッションを作成するにはどうすればよいですか？私はboltクラスのprepareメソッドでラクダのコンテキストをインスタンス化しました。そして、ルートとtibcoの接続はconfigファイルでインスタンス化されています。

キャメル・コンテキストは、以下のリンク内の溶液に応じてインスタンス化されます： Using Apache Camel ProducerTemplate in Apache Storm bolt

Answer 1

あなたは、「TIBCO EMS接続は設定ファイルでインスタンス化されている」と言うとき、私は少し混乱しています。

prepareを覚えていますがのために一度あなたのボルトの各インスタンスを実行しようとしているので、あなたは、TIBCO EMSへの接続を初期化するだろう場所です。 ProducerTemplateのように、executeに何度も何度も何度も再利用するため、接続をtransientにすることができます。

がここに私の他の答えを見てみましょう：Execution flow of a storm program

最後に、あなたがするときは、セットアップトポロジをしたいどのように多くのあなたのボルトのインスタンスを制御します。