3

Paho MQTT をデモンストレーションするために、Java の例をダウンロードしました。

 public class Thermometer {

    public static final String BROKER_URL = "tcp://test.mosquitto.org:1883";

    public static final String TOPIC = "xyz.abc";

    private MqttClient client;


    public Thermometer() {
        try {
            MemoryPersistence per = new MemoryPersistence();
            String clientId = UUID.randomUUID().toString();
            client = new MqttClient(BROKER_URL, clientId, per);
        } catch (MqttException e) {
            e.printStackTrace();
            System.exit(1);
        }
    }

実行すると問題が発生しclient = new MqttClient(BROKER_URL, clientId, per);

スレッド「メイン」での例外 java.lang.IllegalArgumentException org.eclipse.paho.client.mqttv3.MqttClient.(MqttClient.java:170) で mqtt_pub.Thermometer.(Thermometer.java:26) で mqtt_pub.Thermometer.main( Thermometer.java:65)

QoS の値が 0、1、または 2 でない場合、@throws IllegalArgumentException が見つかりましたが、クラス MemoryPersistence では言及されていませんでした。助けてください、よろしくお願いします。

4

1 に答える 1