diff --git a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/manager/LocalProtocolSupportManager.java b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/manager/LocalProtocolSupportManager.java index a27219d3f..ade7b72db 100644 --- a/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/manager/LocalProtocolSupportManager.java +++ b/jetlinks-components/protocol-component/src/main/java/org/jetlinks/community/protocol/manager/LocalProtocolSupportManager.java @@ -134,7 +134,7 @@ public void checkProtocol(EntityCreatedEvent event) { public void checkProtocol(EntityModifyEvent event) { event.async( Flux.fromIterable(event.getAfter()) - .flatMap(entity -> checkProtocol(entity.toDefinition())) + .flatMap(entity -> init(entity.toDefinition())) ); }