diff --git a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java index d7d89bf..6895c7c 100644 --- a/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java +++ b/cloud-modules/cloud-data/src/main/java/com/muyu/data/util/ReceiveTwo.java @@ -7,7 +7,7 @@ public class ReceiveTwo { public static void main(String[] args) { String topic = "vehicle"; String broker = "tcp://47.101.53.251:1883"; - String clientId="lxy"; + String clientId="lw"; try { MqttClient mqttClient= new MqttClient(broker,clientId); @@ -15,12 +15,9 @@ public class ReceiveTwo { connectOptions.setCleanSession(true); System.out.println("Connecting to broker:" + broker); mqttClient.connect(connectOptions); - System.out.println("已连接"); - mqttClient.setCallback(new MqttCallback(){ - @Override public void connectionLost(Throwable throwable) { System.out.println("Connect lost!");