We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0d2e419 commit 27d36daCopy full SHA for 27d36da
qmq-delay-server/src/main/java/qunar/tc/qmq/delay/container/Bootstrap.java
@@ -21,6 +21,9 @@
21
public class Bootstrap {
22
public static void main(String[] args) {
23
ServerWrapper wrapper = new ServerWrapper();
24
+ Runtime.getRuntime().addShutdownHook(new Thread(() -> {
25
+ wrapper.destroy();
26
+ }));
27
wrapper.start();
28
}
29
qmq-server/src/main/java/qunar/tc/qmq/container/Bootstrap.java
@@ -22,6 +22,10 @@
ServerWrapper wrapper = new ServerWrapper(DynamicConfigLoader.load("broker.properties"));
+
30
31
0 commit comments