データベースにmqtt購読されたデータを格納する方法

Question

MQTT Pahoを使用していますMqttCallback問題なく登録してトピックに公開できましたが、データはmessageArrived(String topic, MqttMessage message)にあるデータベースに格納しています私は将来それを使うことができます。

@Override 
public void messageArrived(String topic, MqttMessage message) throws Exception { 
    // code to store the message in database 
    LOGGER.info("messageArrived>> " + message); 
} 

messageArrived()その単純だロガーを実行し、データベースに格納されたコードを実行していません。 データベースにメッセージを格納するコードが正しい場合は、コードをスキップします。 どのような戦略を適用する必要があるのですか？まず、データベースにメッセージを保存し、ログを出力します。

更新

私はそれがPAHOフレームワークによって飲み込ま取得された例外を投げるあなたのロガー/データベースのコードので、これはとなりますthis

Answer 1

に似た何かをしようとしています。

ロガー呼び出しの間にtry/catchブロックを追加します。

@Override 
public void messageArrived(String topic, MqttMessage message) throws Exception { 
    try { 
     // code to store the message in database 
     LOGGER.info("messageArrived>> " + message); 
    } catch (Exception ex) { 
     System.err.println(ex); 
    } 
} 

は、今では