diff --git a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/OhMyWorker.java b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/OhMyWorker.java index 81a6e480..49426e06 100644 --- a/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/OhMyWorker.java +++ b/powerjob-worker/src/main/java/com/github/kfcfans/powerjob/worker/OhMyWorker.java @@ -195,5 +195,6 @@ public class OhMyWorker implements ApplicationContextAware, InitializingBean, Di @Override public void destroy() throws Exception { timingPool.shutdownNow(); + workerRuntime.getActorSystem().terminate(); } }