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 では言及されていませんでした。助けてください、よろしくお願いします。