Use context from existing Vert.x instance during CO startup (#12151)

Signed-off-by: Jakub Scholz <www@scholzj.com>

Author: scholzj

cluster-operator/src/main/java/io/strimzi/operator/cluster/Main.java

@@ -22,7 +22,6 @@
 import io.strimzi.operator.common.Util;
 import io.strimzi.operator.common.model.PasswordGenerator;
 import io.vertx.core.CompositeFuture;
-import io.vertx.core.Context;
 import io.vertx.core.Future;
 import io.vertx.core.Promise;
 import io.vertx.core.Vertx;
@@ -83,7 +82,7 @@ public static void main(String[] args) {
         KubernetesClient client = new OperatorKubernetesClientBuilder("strimzi-cluster-operator", strimziVersion).build();
 
         startHealthServer(vertx, metricsProvider)
-                .compose(i -> leaderElection(client, config, shutdownHook))
+                .compose(i -> leaderElection(vertx, client, config, shutdownHook))
                 .compose(i -> createPlatformFeaturesAvailability(vertx, client))
                 .compose(pfa -> deployClusterOperatorVerticles(vertx, client, metricsProvider, pfa, config, shutdownHook))
                 .onComplete(res -> {
@@ -210,21 +209,21 @@ static CompositeFuture deployClusterOperatorVerticles(Vertx vertx, KubernetesCli
      *
      * When the leader election is disabled, it just completes the future without waiting for anything.
      *
+     * @param vertx         Vert.x instance
      * @param client        Kubernetes client
      * @param config        Cluster Operator configuration
      * @param shutdownHook  Shutdown hook to register leader election shutdown
      */
-    private static Future<Void> leaderElection(KubernetesClient client, ClusterOperatorConfig config, ShutdownHook shutdownHook)    {
+    private static Future<Void> leaderElection(Vertx vertx, KubernetesClient client, ClusterOperatorConfig config, ShutdownHook shutdownHook)    {
         Promise<Void> leader = Promise.promise();
-        Context context = Vertx.currentContext();
 
         if (config.getLeaderElectionConfig() != null) {
             LeaderElectionManager leaderElection = new LeaderElectionManager(
                     client, config.getLeaderElectionConfig(),
                     () -> {
                         // New leader => complete the future
                         LOGGER.info("I'm the new leader");
-                        context.runOnContext(v -> leader.complete());
+                        vertx.runOnContext(v -> leader.complete());
                     },
                     isShuttingDown -> {
                         // Not a leader anymore