1

主な入力として JMS ブローカーを使用する分散 CEP セットアップがあるとします。

ここで、イベントをトピック X に送信するようにクライアント アプリケーションに指示すると、イベントは CEP クラスター内の各ノードに分散されます。これは、各ノードが同じトピック X をリッスンするためです。各ノードが重複データを受信して​​いるため、特定のデータ フィールドをカウントしています。2 ノード クラスタの場合、カウントは実際の値の 2 倍になります)

Topic の代わりに JMS Queue を使用して CEP を使用できますか? このようにして、イベントデータを最初に取得したノードがキューからメッセージを消費しますか? WSO2 CEP は JMS キューをサポートしていますか?

4

1 に答える 1

2

いいえ、現在 (CEP 2.0.1) は JMS キューからのイベントの受信をサポートしていません。ただし、これが要件である場合は、独自の CEP アデプター (ブローカー) を記述して、キューからイベントを受信し、それを CEP にプッシュすることができます。

カスタム ブローカーを作成するには

org.wso2.carbon.broker.core.BrokerType を拡張して適切なブローカー タイプを作成し、jar org.wso2.carbon.broker.core から org.wso2.carbon.broker.core.BrokerTypeFactory を拡張して適切なブローカー タイプ ファクトリを作成します。 -4.0.5.jar

次に、そのブローカーを CEP で構成するには、wso2cep-2.0.1/repository/conf に「broker.xml」というファイルを作成し、次の XML を追加します。 <brokerTypes xmlns="http://wso2.org/carbon/broker"> <brokerType class="<<class reference>>" /> ... </brokerTypes>

カスタム ブローカーの作成に関する詳細なドキュメントは、http://suhothayan.blogspot.com/2013/02/writing-custom-broker-for-wso2-cep.htmlにあります。

于 2013-01-27T12:44:38.490 に答える