1

MQTT パブリッシャーがあるシナリオがあります。

MQTT クライアント --> メッセージ ブローカ --> WSO2 CEP (JMS 入力アダプタ)

この公開された MQTT メッセージを WSO2 CEP への入力として取得するには、どのような方法がありますか?

ActiveMQ をメッセージ ブローカーとして使用し、JMS メッセージをリッスンする CEP JMS 入力アダプターを使用しようとしましたが、ActiveMQ は MQTT メッセージを ByteMessage として変換します。同じセットアップで公開された JMS メッセージが正常に動作しているため、現時点では CEP はそれを処理しないと思います。
WSO2 CEP 4.0.0 には MQTT 入力アダプターの機能があることは知っています。CEP 3.1.0 でどのように処理できますか?

4

2 に答える 2

2

ご指摘のとおり、WSO2 CEP はバージョン 4.0.0 以降の MQTT をサポートしています。新しいバージョンでは入力アダプターのアーキテクチャが異なるため、WSO2 CEP 4.0.0 MQTT コンポーネント/機能を CEP 3.1.0 に追加することはできません。

CEP 4.0.0 を使用することを強くお勧めします。CEP 3.1.0 で本当にこれが必要な場合は、CEP 3.1.0用のカスタム イベント アダプターを作成する必要があります。新しいバージョンのソースを参照してアイデアを得ることができますが、アダプターの実装は異なります。

于 2015-06-12T11:24:45.177 に答える