Skip to content

Commit 263b204

Browse files
committed
Don't install a shutdown hook by default #434
1 parent 255c69f commit 263b204

File tree

1 file changed

+7
-4
lines changed
  • operator-framework-core/src/main/java/io/javaoperatorsdk/operator

1 file changed

+7
-4
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,10 @@
11
package io.javaoperatorsdk.operator;
22

3+
import java.io.Closeable;
4+
import java.io.IOException;
5+
import java.util.ArrayList;
6+
import java.util.List;
7+
38
import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition;
49
import io.fabric8.kubernetes.client.CustomResource;
510
import io.fabric8.kubernetes.client.KubernetesClient;
@@ -8,10 +13,6 @@
813
import io.javaoperatorsdk.operator.api.config.ConfigurationService;
914
import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
1015
import io.javaoperatorsdk.operator.processing.event.DefaultEventSourceManager;
11-
import java.io.Closeable;
12-
import java.io.IOException;
13-
import java.util.ArrayList;
14-
import java.util.List;
1516
import org.slf4j.Logger;
1617
import org.slf4j.LoggerFactory;
1718

@@ -27,7 +28,9 @@ public Operator(KubernetesClient k8sClient, ConfigurationService configurationSe
2728
this.k8sClient = k8sClient;
2829
this.configurationService = configurationService;
2930
this.closeables = new ArrayList<>();
31+
}
3032

33+
public void installShutdownHook() {
3134
Runtime.getRuntime().addShutdownHook(new Thread(this::close));
3235
}
3336

0 commit comments

Comments
 (0)