catch exception

foundations/foundation-common/src/main/java/org/apache/servicecomb/foundation/common/utils/LambdaUtils.java

@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.servicecomb.foundation.common.utils;
+
+import java.util.function.Consumer;
+
+public class LambdaUtils {
+
+  public static <T> Consumer<T> ignoreException(Consumer<T> consumer) {
+    return item -> {
+      try {
+        consumer.accept(item);
+      } catch (Throwable e) {
+      }
+    };
+  }
+}

foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/DiscoveryManager.java

@@ -29,6 +29,7 @@
 
 import org.apache.servicecomb.foundation.common.cache.VersionedCache;
 import org.apache.servicecomb.foundation.common.concurrent.ConcurrentHashMapEx;
+import org.apache.servicecomb.foundation.common.utils.LambdaUtils;
 import org.apache.servicecomb.registry.api.Discovery;
 import org.apache.servicecomb.registry.api.DiscoveryInstance;
 import org.apache.servicecomb.registry.api.LifeCycle;
@@ -318,7 +319,7 @@ public List<? extends DiscoveryInstance> findServiceInstances(String application
 
   @Override
   public void destroy() {
-    discoveryList.forEach(LifeCycle::destroy);
+    discoveryList.forEach(LambdaUtils.ignoreException(LifeCycle::destroy));
     task.shutdownNow();
   }
 

foundations/foundation-registry/src/main/java/org/apache/servicecomb/registry/RegistrationManager.java

@@ -23,6 +23,7 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.stream.Collectors;
 
+import org.apache.servicecomb.foundation.common.utils.LambdaUtils;
 import org.apache.servicecomb.registry.api.LifeCycle;
 import org.apache.servicecomb.registry.api.MicroserviceInstanceStatus;
 import org.apache.servicecomb.registry.api.Registration;
@@ -99,7 +100,7 @@ public void addEndpoint(String endpoint) {
   }
 
   public void destroy() {
-    registrationList.forEach(LifeCycle::destroy);
+    registrationList.forEach(LambdaUtils.ignoreException(LifeCycle::destroy));
   }
 
   public void run() {