From 11f1dc89f398091498b842cb89173220cfb219d4 Mon Sep 17 00:00:00 2001 From: cheyx Date: Sun, 29 Sep 2024 17:33:20 +0800 Subject: [PATCH] add destroyMethod for zookeeperRegistryCenter bean --- .../spring/boot/reg/ElasticJobRegistryCenterConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java b/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java index c6b749c344..7e383a0346 100644 --- a/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java +++ b/spring/boot-starter/src/main/java/org/apache/shardingsphere/elasticjob/spring/boot/reg/ElasticJobRegistryCenterConfiguration.java @@ -33,7 +33,7 @@ public class ElasticJobRegistryCenterConfiguration { * @param zookeeperProperties factory * @return zookeeper registry center */ - @Bean(initMethod = "init") + @Bean(initMethod = "init", destroyMethod = "close") public ZookeeperRegistryCenter zookeeperRegistryCenter(final ZookeeperProperties zookeeperProperties) { return new ZookeeperRegistryCenter(zookeeperProperties.toZookeeperConfiguration()); }