From f0b46e12d1e7e1ee86e4af29d6b3b5f1b1f37426 Mon Sep 17 00:00:00 2001 From: "xueli.xue" Date: Sun, 7 May 2017 18:51:13 +0800 Subject: [PATCH] =?UTF-8?q?JettyServer=E5=85=B3=E9=97=AD=E9=80=BB=E8=BE=91?= =?UTF-8?q?=E4=BC=98=E5=8C=96=EF=BC=8C=E4=BF=AE=E5=A4=8D=E6=89=A7=E8=A1=8C?= =?UTF-8?q?=E5=99=A8=E6=97=A0=E6=B3=95=E9=80=9A=E8=BF=87=E8=84=9A=E6=9C=AC?= =?UTF-8?q?=E6=AD=A3=E5=B8=B8=E5=85=B3=E9=97=AD=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/xxl/job/core/rpc/netcom/jetty/server/JettyServer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/rpc/netcom/jetty/server/JettyServer.java b/xxl-job-core/src/main/java/com/xxl/job/core/rpc/netcom/jetty/server/JettyServer.java index d866fd68..f53949fa 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/rpc/netcom/jetty/server/JettyServer.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/rpc/netcom/jetty/server/JettyServer.java @@ -44,7 +44,7 @@ public class JettyServer { logger.info(">>>>>>>>>>>> xxl-job jetty server start success at port:{}.", port); ExecutorRegistryThread.getInstance().start(port, ip, appName, registHelper); server.join(); // block until thread stopped - logger.info(">>>>>>>>>>> xxl-rpc server start success, netcon={}, port={}", JettyServer.class.getName(), port); + logger.info(">>>>>>>>>>> xxl-rpc server join success, netcon={}, port={}", JettyServer.class.getName(), port); } catch (Exception e) { logger.error("", e); } finally { @@ -59,6 +59,7 @@ public class JettyServer { public void destroy() { if (server != null) { try { + server.stop(); server.destroy(); } catch (Exception e) { logger.error("", e);