MQTT Pahoを使用していますMqttCallback
問題なく登録してトピックに公開できましたが、データはmessageArrived(String topic, MqttMessage message)
にあるデータベースに格納しています私は将来それを使うことができます。データベースにmqtt購読されたデータを格納する方法
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
// code to store the message in database
LOGGER.info("messageArrived>> " + message);
}
messageArrived()
その単純だロガーを実行し、データベースに格納されたコードを実行していません。 データベースにメッセージを格納するコードが正しい場合は、コードをスキップします。 どのような戦略を適用する必要があるのですか?まず、データベースにメッセージを保存し、ログを出力します。
更新
私はそれがPAHOフレームワークによって飲み込ま取得された例外を投げるあなたのロガー/データベースのコードので、これはとなりますthis
あなたはMavenを使用しているstderrに失敗の理由を印刷する必要がありますか? – Jay
はい私はmavenを使用しています –
これはデバッガでこれを実行するとどうなりますか? – Jay