From e4c4b9fe36fcf2d30d857b4e4608bf68fac23755 Mon Sep 17 00:00:00 2001
From: zhou-hao <admin@hsweb.me>
Date: Wed, 24 Feb 2021 19:01:52 +0800
Subject: [PATCH] onErrorResume

---
 .../configuration/LazyInitManagementProtocolSupports.java  | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/LazyInitManagementProtocolSupports.java b/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/LazyInitManagementProtocolSupports.java
index b971201a..7e853dfa 100644
--- a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/LazyInitManagementProtocolSupports.java
+++ b/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/LazyInitManagementProtocolSupports.java
@@ -46,7 +46,7 @@ public class LazyInitManagementProtocolSupports extends StaticProtocolSupports i
                 .filter(de -> de.getState() == 1)
                 .flatMap(this::init)
                 .blockLast(loadTimeOut);
-        } catch (Exception e) {
+        } catch (Throwable e) {
             log.error("load protocol error", e);
         }
 
@@ -73,7 +73,10 @@ public class LazyInitManagementProtocolSupports extends StaticProtocolSupports i
                 configProtocolIdMapping.put(definition.getId(), e.getId());
                 consumer.accept(e);
             })
-            .onErrorContinue((e, obj) -> log.error("{} protocol[{}] error: {}", operation, definition.getId(), e))
+            .onErrorResume((e) -> {
+                log.error("{} protocol[{}] error: {}", operation, definition.getId(), e);
+                return Mono.empty();
+            })
             .then();
 
     }