JMSキューにメッセージを送信するフレームワークがapacheにありますか？

Question

データベースのデータを処理するためにApache Sparkを使用したいと考えています。私は特定の動作を検出すると、一部のユーザーに通知するためにイベント（そのようなアラーム）をトリガーしたい。 1つの方法は、ユーザーがアクセスできるJMSキューにフィードすることです。

したがって、JMSキューにメッセージを送信するためのapacheのフレームワークがありますか？

おかげ

Answer 1

そこには作り付けのフレームワークはありませんが、あなたは以下の、外部システムにデータを送信するためにforEachPartitionsメソッドを使用することができますサンプルコードは

input.foreachRDD(rdd => 
    rdd.foreachPartition(
     partitionOfRecords => 
     { 
      // Create Jms queue Connection Here 

      partitionOfRecords.foreach(messgae => 
      { 
        jsmQueueConnection.send(message) 

      } 
     ) 

     })) 

です