✨ 优化 solon 版本兼容

lets-mica · Oct 11, 2024 · f958dd5 · f958dd5
1 parent 7d9664b
commit f958dd5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ain/java/net/dreamlu/iot/mqtt/client/noear/event/SolonEventMqttClientConnectListener.java b/...ain/java/net/dreamlu/iot/mqtt/client/noear/event/SolonEventMqttClientConnectListener.java
@@ -36,7 +36,7 @@ public void onConnected(ChannelContext context, boolean isReconnect) {
 		} else {
 			log.info("连接 mqtt 服务器成功...");
 		}
-		EventBus.push(new MqttConnectedEvent(isReconnect));
+		EventBus.publish(new MqttConnectedEvent(isReconnect));
 	}
 
 	@Override
@@ -49,7 +49,7 @@ public void onDisconnect(ChannelContext channelContext, Throwable throwable, Str
 			reason = remark + " Exception:" + throwable.getMessage();
 			log.error("mqtt 链接断开 remark:{} isRemove:{}", remark, isRemove, throwable);
 		}
-		EventBus.push(new MqttDisconnectEvent(reason, isRemove));
+		EventBus.publish(new MqttDisconnectEvent(reason, isRemove));
 	}
 
 }