MQTT非同期メッセージへのアクセス

Question

MQTTを介していくつかのトピックにサブスクライブされるリスナー・クラス（Java）があります。私は別のクラスの私のリスナーに公開されているメッセージにアクセスしたいです。しかし、私はこれを行う方法がわからない。 目標は、リスナークラスの出力を連続的にリフレッシュするJFrameに供給することです 提案はありますか？ありがとう。

Answer 1

あなたはいくつかのトピックにサブスクライブする必要があり、クライアント

private MqttClient sampleClient; 

あります

sampleClient.subscribe(topicToSubscribe); 

、あなたはブローカーがあなたに推進しているという情報を得ることができるので、CALLBACKを設定する（これはあなたが欠けているものを確認してください）

sampleClient.setCallback(new MqttCallback() { 

    @Override 
    public void messageArrived(String topicInforming, MqttMessage mqttMessage) throws Exception { 
       System.out.println("messageArrived: " + mqttMessage.toString()); 
      } 

    @Override 
    public void deliveryComplete(IMqttDeliveryToken arg0) { 
       System.out.println("DeliveryComplete: " + arg0.getMessageId()); 
      } 

    @Override 
    public void connectionLost(Throwable arg0) { 
       System.err.println("Connection lost: " + arg0.getMessage()); 
    } 
});