We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 55ccdb9 commit f5a2bafCopy full SHA for f5a2baf
iot-backend/src/main/java/iot/microservice/service/MqttListenerService.java
@@ -65,6 +65,9 @@ public void init() {
65
66
Thread.sleep(30000); // Wait 30 sec
67
} catch (Exception e) {
68
+ if (e instanceof MqttException me) {
69
+ System.err.println("[MQTT] ReasonCode=" + me.getReasonCode() + ", Message=" + me.getMessage());
70
+ }
71
e.printStackTrace();
72
try {
73
Thread.sleep(5000); // Retry after 5 sec
0 commit comments