io.vertx/vertx-service-discovery-bridge-zookeeper/4.0.0 : io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.class

ZookeeperServiceImporter
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-service-discovery-parent/vertx-service-discovery-bridge-zookeeper: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse)
public class io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter implements io.vertx.servicediscovery.spi.ServiceImporter, org.apache.curator.framework.recipes.cache.TreeCacheListener
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter
  super_class: java.lang.Object
{
  private static final io.vertx.core.impl.logging.Logger LOGGER;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private io.vertx.servicediscovery.spi.ServicePublisher publisher;
    descriptor: Lio/vertx/servicediscovery/spi/ServicePublisher;
    flags: (0x0002) ACC_PRIVATE

  private org.apache.curator.framework.CuratorFramework client;
    descriptor: Lorg/apache/curator/framework/CuratorFramework;
    flags: (0x0002) ACC_PRIVATE

  private org.apache.curator.x.discovery.ServiceDiscovery<io.vertx.core.json.JsonObject> discovery;
    descriptor: Lorg/apache/curator/x/discovery/ServiceDiscovery;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lorg/apache/curator/x/discovery/ServiceDiscovery<Lio/vertx/core/json/JsonObject;>;

  private org.apache.curator.framework.recipes.cache.TreeCache cache;
    descriptor: Lorg/apache/curator/framework/recipes/cache/TreeCache;
    flags: (0x0002) ACC_PRIVATE

  private volatile boolean started;
    descriptor: Z
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private java.util.Set<io.vertx.servicediscovery.zookeeper.RegistrationHolder<org.apache.curator.x.discovery.ServiceInstance<io.vertx.core.json.JsonObject>>> registrations;
    descriptor: Ljava/util/Set;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/Set<Lio/vertx/servicediscovery/zookeeper/RegistrationHolder<Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;>;>;

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 36
            ldc Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
            putstatic io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
         0: .line 34
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 43
            aload 0 /* this */
            new io.vertx.core.impl.ConcurrentHashSet
            dup
            invokespecial io.vertx.core.impl.ConcurrentHashSet.<init>:()V
            putfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.registrations:Ljava/util/Set;
         2: .line 34
            return
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;

  public void start(io.vertx.core.Vertx, io.vertx.servicediscovery.spi.ServicePublisher, io.vertx.core.json.JsonObject, io.vertx.core.Promise<java.lang.Void>);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/servicediscovery/spi/ServicePublisher;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Promise;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=11, args_size=5
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.vertx.servicediscovery.spi.ServicePublisher publisher
        start local 3 // io.vertx.core.json.JsonObject configuration
        start local 4 // io.vertx.core.Promise future
         0: .line 47
            aload 0 /* this */
            aload 2 /* publisher */
            putfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
         1: .line 49
            aload 3 /* configuration */
            ldc "connection"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.String
            astore 5 /* connection */
        start local 5 // java.lang.String connection
         2: .line 50
            aload 3 /* configuration */
            ldc "maxRetries"
            iconst_3
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
            invokevirtual java.lang.Integer.intValue:()I
            istore 6 /* maxRetries */
        start local 6 // int maxRetries
         3: .line 51
            aload 3 /* configuration */
            ldc "baseSleepTimeBetweenRetries"
            sipush 1000
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
            invokevirtual java.lang.Integer.intValue:()I
            istore 7 /* baseGraceBetweenRetries */
        start local 7 // int baseGraceBetweenRetries
         4: .line 52
            aload 3 /* configuration */
            ldc "basePath"
            ldc "/discovery"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            astore 8 /* basePath */
        start local 8 // java.lang.String basePath
         5: .line 53
            aload 3 /* configuration */
            ldc "canBeReadOnly"
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
            invokevirtual java.lang.Boolean.booleanValue:()Z
            istore 9 /* canBeReadOnly */
        start local 9 // boolean canBeReadOnly
         6: .line 54
            aload 3 /* configuration */
            ldc "connectionTimeoutMs"
            sipush 1000
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
            invokevirtual java.lang.Integer.intValue:()I
            istore 10 /* connectionTimeoutMs */
        start local 10 // int connectionTimeoutMs
         7: .line 56
            aload 1 /* vertx */
         8: .line 57
            aload 0 /* this */
            iload 9 /* canBeReadOnly */
            aload 5 /* connection */
            iload 10 /* connectionTimeoutMs */
            iload 7 /* baseGraceBetweenRetries */
            iload 6 /* maxRetries */
            aload 8 /* basePath */
            aload 4 /* future */
            invokedynamic handle(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;ZLjava/lang/String;IIILjava/lang/String;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$0(ZLjava/lang/String;IIILjava/lang/String;Lio/vertx/core/Promise;Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
         9: .line 86
            aload 0 /* this */
            aload 4 /* future */
            invokedynamic handle(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$1(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
        10: .line 56
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
        11: .line 102
            return
        end local 10 // int connectionTimeoutMs
        end local 9 // boolean canBeReadOnly
        end local 8 // java.lang.String basePath
        end local 7 // int baseGraceBetweenRetries
        end local 6 // int maxRetries
        end local 5 // java.lang.String connection
        end local 4 // io.vertx.core.Promise future
        end local 3 // io.vertx.core.json.JsonObject configuration
        end local 2 // io.vertx.servicediscovery.spi.ServicePublisher publisher
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot                     Name  Signature
            0   12     0                     this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0   12     1                    vertx  Lio/vertx/core/Vertx;
            0   12     2                publisher  Lio/vertx/servicediscovery/spi/ServicePublisher;
            0   12     3            configuration  Lio/vertx/core/json/JsonObject;
            0   12     4                   future  Lio/vertx/core/Promise<Ljava/lang/Void;>;
            2   12     5               connection  Ljava/lang/String;
            3   12     6               maxRetries  I
            4   12     7  baseGraceBetweenRetries  I
            5   12     8                 basePath  Ljava/lang/String;
            6   12     9            canBeReadOnly  Z
            7   12    10      connectionTimeoutMs  I
    Signature: (Lio/vertx/core/Vertx;Lio/vertx/servicediscovery/spi/ServicePublisher;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
    MethodParameters:
               Name  Flags
      vertx          
      publisher      
      configuration  
      future         

  private synchronized void compute(io.vertx.core.Promise<java.lang.Void>);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=6, args_size=2
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // io.vertx.core.Promise done
         0: .line 105
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* instances */
        start local 2 // java.util.List instances
         1: .line 107
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.discovery:Lorg/apache/curator/x/discovery/ServiceDiscovery;
            invokeinterface org.apache.curator.x.discovery.ServiceDiscovery.queryForNames:()Ljava/util/Collection;
            astore 3 /* names */
        start local 3 // java.util.Collection names
         2: .line 108
            aload 3 /* names */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 5
            goto 5
      StackMap locals: io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter io.vertx.core.Promise java.util.List java.util.Collection top java.util.Iterator
      StackMap stack:
         3: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.lang.String
            astore 4 /* name */
        start local 4 // java.lang.String name
         4: .line 109
            aload 2 /* instances */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.discovery:Lorg/apache/curator/x/discovery/ServiceDiscovery;
            aload 4 /* name */
            invokeinterface org.apache.curator.x.discovery.ServiceDiscovery.queryForInstances:(Ljava/lang/String;)Ljava/util/Collection;
            invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
            pop
        end local 4 // java.lang.String name
         5: .line 108
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
        end local 3 // java.util.Collection names
         6: .line 111
            goto 14
      StackMap locals: io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter io.vertx.core.Promise java.util.List
      StackMap stack: org.apache.zookeeper.KeeperException$NoNodeException
         7: pop
            goto 14
         8: .line 114
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 3 /* e */
        start local 3 // java.lang.Exception e
         9: .line 115
            aload 1 /* done */
            ifnull 12
        10: .line 116
            aload 1 /* done */
            aload 3 /* e */
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
        11: .line 117
            goto 14
        12: .line 118
      StackMap locals: java.lang.Exception
      StackMap stack:
            getstatic io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            ldc "Unable to retrieve service instances from Zookeeper"
            aload 3 /* e */
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        13: .line 119
            return
        end local 3 // java.lang.Exception e
        14: .line 124
      StackMap locals:
      StackMap stack:
            new java.util.HashSet
            dup
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.registrations:Ljava/util/Set;
            invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
        15: .line 123
            astore 3 /* registered */
        start local 3 // java.util.Set registered
        16: .line 125
            new java.util.HashSet
            dup
            aload 2 /* instances */
            invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
            astore 4 /* remote */
        start local 4 // java.util.Set remote
        17: .line 127
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 5 /* actions */
        start local 5 // java.util.List actions
        18: .line 129
            aload 3 /* registered */
            aload 2 /* instances */
            invokestatic io.vertx.servicediscovery.zookeeper.RegistrationHolder.filter:(Ljava/util/Set;Ljava/util/Collection;)Ljava/util/Set;
        19: .line 130
            invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
        20: .line 131
            aload 0 /* this */
            invokedynamic apply(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;)Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$3(Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;)Lio/vertx/core/Future; (7)
                  (Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;)Lio/vertx/core/Future;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
        21: .line 142
            aload 5 /* actions */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic accept(Ljava/util/List;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  java/util/List.add(Ljava/lang/Object;)Z (9 itf)
                  (Lio/vertx/core/Future;)V
            invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
        22: .line 144
            aload 4 /* remote */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.registrations:Ljava/util/Set;
            invokestatic io.vertx.servicediscovery.zookeeper.RegistrationHolder.filter:(Ljava/util/Set;Ljava/util/Set;)Ljava/util/Set;
        23: .line 145
            invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
        24: .line 146
            aload 0 /* this */
            invokedynamic apply(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;)Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$6(Lorg/apache/curator/x/discovery/ServiceInstance;)Lio/vertx/core/Future; (7)
                  (Lorg/apache/curator/x/discovery/ServiceInstance;)Lio/vertx/core/Future;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
        25: .line 157
            aload 5 /* actions */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic accept(Ljava/util/List;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  java/util/List.add(Ljava/lang/Object;)Z (9 itf)
                  (Lio/vertx/core/Future;)V
            invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
        26: .line 159
            aload 1 /* done */
            ifnull 28
        27: .line 160
            aload 5 /* actions */
            invokestatic io.vertx.core.CompositeFuture.all:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
            aload 1 /* done */
            invokedynamic handle(Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$9(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.CompositeFuture.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/CompositeFuture;
            pop
        28: .line 169
      StackMap locals: java.util.Set java.util.Set java.util.List
      StackMap stack:
            return
        end local 5 // java.util.List actions
        end local 4 // java.util.Set remote
        end local 3 // java.util.Set registered
        end local 2 // java.util.List instances
        end local 1 // io.vertx.core.Promise done
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   29     0        this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0   29     1        done  Lio/vertx/core/Promise<Ljava/lang/Void;>;
            1   29     2   instances  Ljava/util/List<Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;>;
            2    6     3       names  Ljava/util/Collection<Ljava/lang/String;>;
            4    5     4        name  Ljava/lang/String;
            9   14     3           e  Ljava/lang/Exception;
           16   29     3  registered  Ljava/util/Set<Lio/vertx/servicediscovery/zookeeper/RegistrationHolder<Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;>;>;
           17   29     4      remote  Ljava/util/Set<Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;>;
           18   29     5     actions  Ljava/util/List<Lio/vertx/core/Future;>;
      Exception table:
        from    to  target  type
           1     6       7  Class org.apache.zookeeper.KeeperException$NoNodeException
           1     6       8  Class java.lang.Exception
    Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
    MethodParameters:
      Name  Flags
      done  

  static io.vertx.servicediscovery.Record createRecordForInstance(org.apache.curator.x.discovery.ServiceInstance<io.vertx.core.json.JsonObject>);
    descriptor: (Lorg/apache/curator/x/discovery/ServiceInstance;)Lio/vertx/servicediscovery/Record;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // org.apache.curator.x.discovery.ServiceInstance instance
         0: .line 172
            new io.vertx.servicediscovery.Record
            dup
            invokespecial io.vertx.servicediscovery.Record.<init>:()V
            astore 1 /* record */
        start local 1 // io.vertx.servicediscovery.Record record
         1: .line 173
            aload 1 /* record */
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getName:()Ljava/lang/String;
            invokevirtual io.vertx.servicediscovery.Record.setName:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
            pop
         2: .line 174
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getPayload:()Ljava/lang/Object;
            checkcast io.vertx.core.json.JsonObject
            astore 2 /* payload */
        start local 2 // io.vertx.core.json.JsonObject payload
         3: .line 175
            aload 1 /* record */
            aload 2 /* payload */
            invokevirtual io.vertx.servicediscovery.Record.setMetadata:(Lio/vertx/core/json/JsonObject;)Lio/vertx/servicediscovery/Record;
            pop
         4: .line 176
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getMetadata:()Lio/vertx/core/json/JsonObject;
            ldc "zookeeper-service-type"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getServiceType:()Lorg/apache/curator/x/discovery/ServiceType;
            invokevirtual org.apache.curator.x.discovery.ServiceType.toString:()Ljava/lang/String;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
         5: .line 177
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getMetadata:()Lio/vertx/core/json/JsonObject;
            ldc "zookeeper-address"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getAddress:()Ljava/lang/String;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
         6: .line 178
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getMetadata:()Lio/vertx/core/json/JsonObject;
            ldc "zookeeper-registration-time"
         7: .line 179
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getRegistrationTimeUTC:()J
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
         8: .line 178
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
         9: .line 180
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getMetadata:()Lio/vertx/core/json/JsonObject;
            ldc "zookeeper-port"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getPort:()Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        10: .line 181
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getMetadata:()Lio/vertx/core/json/JsonObject;
            ldc "zookeeper-ssl-port"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getSslPort:()Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        11: .line 182
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getMetadata:()Lio/vertx/core/json/JsonObject;
            ldc "zookeeper-id"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getId:()Ljava/lang/String;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        12: .line 184
            aload 1 /* record */
            new io.vertx.core.json.JsonObject
            dup
            invokespecial io.vertx.core.json.JsonObject.<init>:()V
            invokevirtual io.vertx.servicediscovery.Record.setLocation:(Lio/vertx/core/json/JsonObject;)Lio/vertx/servicediscovery/Record;
            pop
        13: .line 185
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getUriSpec:()Lorg/apache/curator/x/discovery/UriSpec;
            ifnull 17
        14: .line 186
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.buildUriSpec:()Ljava/lang/String;
            astore 3 /* uri */
        start local 3 // java.lang.String uri
        15: .line 187
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            ldc "endpoint"
            aload 3 /* uri */
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        end local 3 // java.lang.String uri
        16: .line 188
            goto 26
        17: .line 189
      StackMap locals: io.vertx.servicediscovery.Record io.vertx.core.json.JsonObject
      StackMap stack:
            ldc "http"
            astore 3 /* uri */
        start local 3 // java.lang.String uri
        18: .line 190
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getSslPort:()Ljava/lang/Integer;
            ifnull 21
        19: .line 191
            new java.lang.StringBuilder
            dup
            aload 3 /* uri */
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc "s://"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getAddress:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ":"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getSslPort:()Ljava/lang/Integer;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            astore 3 /* uri */
        20: .line 192
            goto 25
      StackMap locals: java.lang.String
      StackMap stack:
        21: aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getPort:()Ljava/lang/Integer;
            ifnull 24
        22: .line 193
            new java.lang.StringBuilder
            dup
            aload 3 /* uri */
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc "s://"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getAddress:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ":"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getPort:()Ljava/lang/Integer;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            astore 3 /* uri */
        23: .line 194
            goto 25
        24: .line 195
      StackMap locals:
      StackMap stack:
            new java.lang.StringBuilder
            dup
            aload 3 /* uri */
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc "://"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getAddress:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            astore 3 /* uri */
        25: .line 197
      StackMap locals:
      StackMap stack:
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            ldc "endpoint"
            aload 3 /* uri */
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        end local 3 // java.lang.String uri
        26: .line 199
      StackMap locals:
      StackMap stack:
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getPort:()Ljava/lang/Integer;
            ifnull 28
        27: .line 200
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            ldc "port"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getPort:()Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        28: .line 202
      StackMap locals:
      StackMap stack:
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getSslPort:()Ljava/lang/Integer;
            ifnull 30
        29: .line 203
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            ldc "ssl-port"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getSslPort:()Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        30: .line 205
      StackMap locals:
      StackMap stack:
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getAddress:()Ljava/lang/String;
            ifnull 32
        31: .line 206
            aload 1 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            ldc "address"
            aload 0 /* instance */
            invokevirtual org.apache.curator.x.discovery.ServiceInstance.getAddress:()Ljava/lang/String;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        32: .line 209
      StackMap locals:
      StackMap stack:
            aload 1 /* record */
            aload 2 /* payload */
            ldc "service-type"
            ldc "unknown"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            invokevirtual io.vertx.servicediscovery.Record.setType:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
            pop
        33: .line 211
            aload 1 /* record */
            areturn
        end local 2 // io.vertx.core.json.JsonObject payload
        end local 1 // io.vertx.servicediscovery.Record record
        end local 0 // org.apache.curator.x.discovery.ServiceInstance instance
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   34     0  instance  Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;
            1   34     1    record  Lio/vertx/servicediscovery/Record;
            3   34     2   payload  Lio/vertx/core/json/JsonObject;
           15   16     3       uri  Ljava/lang/String;
           18   26     3       uri  Ljava/lang/String;
    Signature: (Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;)Lio/vertx/servicediscovery/Record;
    MethodParameters:
          Name  Flags
      instance  

  public void close(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // io.vertx.core.Handler closeHandler
         0: .line 217
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* done */
        start local 2 // io.vertx.core.Promise done
         1: .line 218
            aload 0 /* this */
            aload 2 /* done */
            invokevirtual io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.unregisterAllServices:(Lio/vertx/core/Promise;)V
         2: .line 220
            aload 2 /* done */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 0 /* this */
            aload 1 /* closeHandler */
            invokedynamic handle(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$10(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 230
            return
        end local 2 // io.vertx.core.Promise done
        end local 1 // io.vertx.core.Handler closeHandler
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0          this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    4     1  closeHandler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
            1    4     2          done  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
    MethodParameters:
              Name  Flags
      closeHandler  

  public void childEvent(org.apache.curator.framework.CuratorFramework, org.apache.curator.framework.recipes.cache.TreeCacheEvent);
    descriptor: (Lorg/apache/curator/framework/CuratorFramework;Lorg/apache/curator/framework/recipes/cache/TreeCacheEvent;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // org.apache.curator.framework.CuratorFramework curatorFramework
        start local 2 // org.apache.curator.framework.recipes.cache.TreeCacheEvent treeCacheEvent
         0: .line 235
            aload 2 /* treeCacheEvent */
            invokevirtual org.apache.curator.framework.recipes.cache.TreeCacheEvent.getType:()Lorg/apache/curator/framework/recipes/cache/TreeCacheEvent$Type;
            getstatic org.apache.curator.framework.recipes.cache.TreeCacheEvent$Type.INITIALIZED:Lorg/apache/curator/framework/recipes/cache/TreeCacheEvent$Type;
            if_acmpne 3
         1: .line 236
            aload 0 /* this */
            iconst_1
            putfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.started:Z
         2: .line 237
            goto 5
      StackMap locals:
      StackMap stack:
         3: aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.started:Z
            ifeq 5
         4: .line 238
            aload 0 /* this */
            aconst_null
            invokevirtual io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.compute:(Lio/vertx/core/Promise;)V
         5: .line 240
      StackMap locals:
      StackMap stack:
            return
        end local 2 // org.apache.curator.framework.recipes.cache.TreeCacheEvent treeCacheEvent
        end local 1 // org.apache.curator.framework.CuratorFramework curatorFramework
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    6     0              this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    6     1  curatorFramework  Lorg/apache/curator/framework/CuratorFramework;
            0    6     2    treeCacheEvent  Lorg/apache/curator/framework/recipes/cache/TreeCacheEvent;
    MethodParameters:
                  Name  Flags
      curatorFramework  
      treeCacheEvent    

  private synchronized void unregisterAllServices(io.vertx.core.Promise<java.lang.Void>);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // io.vertx.core.Promise done
         0: .line 243
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* list */
        start local 2 // java.util.List list
         1: .line 245
            new java.util.HashSet
            dup
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.registrations:Ljava/util/Set;
            invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
            aload 0 /* this */
            invokedynamic accept(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$11(Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;)V (7)
                  (Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;)V
            invokevirtual java.util.HashSet.forEach:(Ljava/util/function/Consumer;)V
         2: .line 249
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.registrations:Ljava/util/Set;
            invokeinterface java.util.Set.clear:()V
         3: .line 251
            aload 2 /* list */
            invokestatic io.vertx.core.CompositeFuture.all:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
            aload 1 /* done */
            invokedynamic handle(Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$12(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.CompositeFuture.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/CompositeFuture;
            pop
         4: .line 258
            return
        end local 2 // java.util.List list
        end local 1 // io.vertx.core.Promise done
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    5     1  done  Lio/vertx/core/Promise<Ljava/lang/Void;>;
            1    5     2  list  Ljava/util/List<Lio/vertx/core/Future;>;
    Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
    MethodParameters:
      Name  Flags
      done  

  private void lambda$0(boolean, java.lang.String, int, int, int, java.lang.String, io.vertx.core.Promise, io.vertx.core.Promise);
    descriptor: (ZLjava/lang/String;IIILjava/lang/String;Lio/vertx/core/Promise;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=10, args_size=9
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 8 // io.vertx.core.Promise f
         0: .line 60
            aload 0 /* this */
            invokestatic org.apache.curator.framework.CuratorFrameworkFactory.builder:()Lorg/apache/curator/framework/CuratorFrameworkFactory$Builder;
         1: .line 61
            iload 1
            invokevirtual org.apache.curator.framework.CuratorFrameworkFactory$Builder.canBeReadOnly:(Z)Lorg/apache/curator/framework/CuratorFrameworkFactory$Builder;
         2: .line 62
            aload 2
            invokevirtual org.apache.curator.framework.CuratorFrameworkFactory$Builder.connectString:(Ljava/lang/String;)Lorg/apache/curator/framework/CuratorFrameworkFactory$Builder;
         3: .line 63
            iload 3
            invokevirtual org.apache.curator.framework.CuratorFrameworkFactory$Builder.connectionTimeoutMs:(I)Lorg/apache/curator/framework/CuratorFrameworkFactory$Builder;
         4: .line 64
            new org.apache.curator.retry.ExponentialBackoffRetry
            dup
            iload 4
            iload 5
            invokespecial org.apache.curator.retry.ExponentialBackoffRetry.<init>:(II)V
            invokevirtual org.apache.curator.framework.CuratorFrameworkFactory$Builder.retryPolicy:(Lorg/apache/curator/RetryPolicy;)Lorg/apache/curator/framework/CuratorFrameworkFactory$Builder;
         5: .line 65
            invokevirtual org.apache.curator.framework.CuratorFrameworkFactory$Builder.build:()Lorg/apache/curator/framework/CuratorFramework;
         6: .line 60
            putfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.client:Lorg/apache/curator/framework/CuratorFramework;
         7: .line 66
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.client:Lorg/apache/curator/framework/CuratorFramework;
            invokeinterface org.apache.curator.framework.CuratorFramework.start:()V
         8: .line 68
            aload 0 /* this */
            ldc Lio/vertx/core/json/JsonObject;
            invokestatic org.apache.curator.x.discovery.ServiceDiscoveryBuilder.builder:(Ljava/lang/Class;)Lorg/apache/curator/x/discovery/ServiceDiscoveryBuilder;
         9: .line 69
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.client:Lorg/apache/curator/framework/CuratorFramework;
            invokevirtual org.apache.curator.x.discovery.ServiceDiscoveryBuilder.client:(Lorg/apache/curator/framework/CuratorFramework;)Lorg/apache/curator/x/discovery/ServiceDiscoveryBuilder;
        10: .line 70
            aload 6
            invokevirtual org.apache.curator.x.discovery.ServiceDiscoveryBuilder.basePath:(Ljava/lang/String;)Lorg/apache/curator/x/discovery/ServiceDiscoveryBuilder;
        11: .line 71
            new io.vertx.servicediscovery.zookeeper.JsonObjectSerializer
            dup
            invokespecial io.vertx.servicediscovery.zookeeper.JsonObjectSerializer.<init>:()V
            invokevirtual org.apache.curator.x.discovery.ServiceDiscoveryBuilder.serializer:(Lorg/apache/curator/x/discovery/details/InstanceSerializer;)Lorg/apache/curator/x/discovery/ServiceDiscoveryBuilder;
        12: .line 72
            iconst_1
            invokevirtual org.apache.curator.x.discovery.ServiceDiscoveryBuilder.watchInstances:(Z)Lorg/apache/curator/x/discovery/ServiceDiscoveryBuilder;
        13: .line 73
            invokevirtual org.apache.curator.x.discovery.ServiceDiscoveryBuilder.build:()Lorg/apache/curator/x/discovery/ServiceDiscovery;
        14: .line 68
            putfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.discovery:Lorg/apache/curator/x/discovery/ServiceDiscovery;
        15: .line 75
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.discovery:Lorg/apache/curator/x/discovery/ServiceDiscovery;
            invokeinterface org.apache.curator.x.discovery.ServiceDiscovery.start:()V
        16: .line 77
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.client:Lorg/apache/curator/framework/CuratorFramework;
            aload 6
            invokestatic org.apache.curator.framework.recipes.cache.TreeCache.newBuilder:(Lorg/apache/curator/framework/CuratorFramework;Ljava/lang/String;)Lorg/apache/curator/framework/recipes/cache/TreeCache$Builder;
            invokevirtual org.apache.curator.framework.recipes.cache.TreeCache$Builder.build:()Lorg/apache/curator/framework/recipes/cache/TreeCache;
            putfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.cache:Lorg/apache/curator/framework/recipes/cache/TreeCache;
        17: .line 78
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.cache:Lorg/apache/curator/framework/recipes/cache/TreeCache;
            invokevirtual org.apache.curator.framework.recipes.cache.TreeCache.start:()Lorg/apache/curator/framework/recipes/cache/TreeCache;
            pop
        18: .line 79
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.cache:Lorg/apache/curator/framework/recipes/cache/TreeCache;
            invokevirtual org.apache.curator.framework.recipes.cache.TreeCache.getListenable:()Lorg/apache/curator/framework/listen/Listenable;
            aload 0 /* this */
            invokeinterface org.apache.curator.framework.listen.Listenable.addListener:(Ljava/lang/Object;)V
        19: .line 81
            aload 8 /* f */
            invokeinterface io.vertx.core.Promise.complete:()V
        20: .line 82
            goto 23
      StackMap locals:
      StackMap stack: java.lang.Exception
        21: astore 9 /* e */
        start local 9 // java.lang.Exception e
        22: .line 83
            aload 7
            aload 9 /* e */
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
        end local 9 // java.lang.Exception e
        23: .line 85
      StackMap locals:
      StackMap stack:
            return
        end local 8 // io.vertx.core.Promise f
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   24     0  this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0   24     8     f  Lio/vertx/core/Promise<Ljava/lang/Void;>;
           22   23     9     e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0    20      21  Class java.lang.Exception

  private void lambda$1(io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 87
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 3
         1: .line 88
            aload 1
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         2: .line 89
            goto 6
         3: .line 90
      StackMap locals:
      StackMap stack:
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 3 /* p */
        start local 3 // io.vertx.core.Promise p
         4: .line 91
            aload 3 /* p */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 1
            invokedynamic handle(Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$2(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         5: .line 98
            aload 0 /* this */
            aload 3 /* p */
            invokevirtual io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.compute:(Lio/vertx/core/Promise;)V
        end local 3 // io.vertx.core.Promise p
         6: .line 100
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    7     2    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
            4    6     3     p  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private io.vertx.core.Future lambda$3(io.vertx.servicediscovery.zookeeper.RegistrationHolder);
    descriptor: (Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;)Lio/vertx/core/Future;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // io.vertx.servicediscovery.zookeeper.RegistrationHolder reg
         0: .line 132
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 133
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aload 1 /* reg */
            invokevirtual io.vertx.servicediscovery.zookeeper.RegistrationHolder.record:()Lio/vertx/servicediscovery/Record;
            invokevirtual io.vertx.servicediscovery.Record.getRegistration:()Ljava/lang/String;
            aload 0 /* this */
            aload 1 /* reg */
            aload 2 /* promise */
            invokedynamic handle(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$4(Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.servicediscovery.spi.ServicePublisher.unpublish:(Ljava/lang/String;Lio/vertx/core/Handler;)V
         2: .line 141
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // io.vertx.servicediscovery.zookeeper.RegistrationHolder reg
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    3     1      reg  Lio/vertx/servicediscovery/zookeeper/RegistrationHolder<Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;>;
            1    3     2  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private io.vertx.core.Future lambda$6(org.apache.curator.x.discovery.ServiceInstance);
    descriptor: (Lorg/apache/curator/x/discovery/ServiceInstance;)Lio/vertx/core/Future;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // org.apache.curator.x.discovery.ServiceInstance instance
         0: .line 147
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 148
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aload 1 /* instance */
            invokestatic io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.createRecordForInstance:(Lorg/apache/curator/x/discovery/ServiceInstance;)Lio/vertx/servicediscovery/Record;
            aload 0 /* this */
            aload 1 /* instance */
            aload 2 /* promise */
            invokedynamic handle(Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;Lorg/apache/curator/x/discovery/ServiceInstance;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.lambda$7(Lorg/apache/curator/x/discovery/ServiceInstance;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.servicediscovery.spi.ServicePublisher.publish:(Lio/vertx/servicediscovery/Record;Lio/vertx/core/Handler;)V
         2: .line 156
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // org.apache.curator.x.discovery.ServiceInstance instance
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    3     1  instance  Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;
            1    3     2   promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$9(io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar
         0: .line 161
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 162
            aload 0
            aconst_null
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         2: .line 163
            goto 4
         3: .line 164
      StackMap locals:
      StackMap stack:
            aload 0
            aload 1 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         4: .line 166
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     1    ar  Lio/vertx/core/AsyncResult<Lio/vertx/core/CompositeFuture;>;

  private void lambda$10(io.vertx.core.Handler, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 2 // io.vertx.core.AsyncResult v
         0: .line 222
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.cache:Lorg/apache/curator/framework/recipes/cache/TreeCache;
            invokevirtual org.apache.curator.framework.recipes.cache.TreeCache.close:()V
         1: .line 223
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.discovery:Lorg/apache/curator/x/discovery/ServiceDiscovery;
            invokeinterface org.apache.curator.x.discovery.ServiceDiscovery.close:()V
         2: .line 224
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.client:Lorg/apache/curator/framework/CuratorFramework;
            invokeinterface org.apache.curator.framework.CuratorFramework.close:()V
         3: .line 225
            goto 5
      StackMap locals:
      StackMap stack: java.lang.Exception
         4: pop
         5: .line 228
      StackMap locals:
      StackMap stack:
            aload 1
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         6: .line 229
            return
        end local 2 // io.vertx.core.AsyncResult v
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    7     2     v  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
      Exception table:
        from    to  target  type
           0     3       4  Class java.lang.Exception

  private void lambda$11(io.vertx.servicediscovery.zookeeper.RegistrationHolder);
    descriptor: (Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 1 // io.vertx.servicediscovery.zookeeper.RegistrationHolder reg
         0: .line 246
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* unreg */
        start local 2 // io.vertx.core.Promise unreg
         1: .line 247
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aload 1 /* reg */
            invokevirtual io.vertx.servicediscovery.zookeeper.RegistrationHolder.record:()Lio/vertx/servicediscovery/Record;
            invokevirtual io.vertx.servicediscovery.Record.getRegistration:()Ljava/lang/String;
            aload 2 /* unreg */
            invokeinterface io.vertx.servicediscovery.spi.ServicePublisher.unpublish:(Ljava/lang/String;Lio/vertx/core/Handler;)V
        end local 2 // io.vertx.core.Promise unreg
         2: .line 248
            return
        end local 1 // io.vertx.servicediscovery.zookeeper.RegistrationHolder reg
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    3     0   this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    3     1    reg  Lio/vertx/servicediscovery/zookeeper/RegistrationHolder<Lorg/apache/curator/x/discovery/ServiceInstance<Lio/vertx/core/json/JsonObject;>;>;
            1    2     2  unreg  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$12(io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult x
         0: .line 252
            aload 1 /* x */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 3
         1: .line 253
            aload 0
            aload 1 /* x */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         2: .line 254
            goto 4
         3: .line 255
      StackMap locals:
      StackMap stack:
            aload 0
            invokeinterface io.vertx.core.Promise.complete:()V
         4: .line 257
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult x
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     1     x  Lio/vertx/core/AsyncResult<Lio/vertx/core/CompositeFuture;>;

  private static void lambda$2(io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult x
         0: .line 92
            aload 1 /* x */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 3
         1: .line 93
            aload 0
            aload 1 /* x */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         2: .line 94
            goto 4
         3: .line 95
      StackMap locals:
      StackMap stack:
            aload 0
            aconst_null
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         4: .line 97
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult x
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     1     x  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private void lambda$4(io.vertx.servicediscovery.zookeeper.RegistrationHolder, io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/servicediscovery/zookeeper/RegistrationHolder;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=4
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 3 // io.vertx.core.AsyncResult v
         0: .line 134
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.registrations:Ljava/util/Set;
            aload 1
            invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
            pop
         1: .line 135
            aload 3 /* v */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         2: .line 136
            aload 2
            aconst_null
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         3: .line 137
            goto 5
         4: .line 138
      StackMap locals:
      StackMap stack:
            aload 2
            aload 3 /* v */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         5: .line 140
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.AsyncResult v
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    6     3     v  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private void lambda$7(org.apache.curator.x.discovery.ServiceInstance, io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lorg/apache/curator/x/discovery/ServiceInstance;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
        start local 3 // io.vertx.core.AsyncResult v
         0: .line 149
            aload 3 /* v */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 150
            aload 0 /* this */
            getfield io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter.registrations:Ljava/util/Set;
            new io.vertx.servicediscovery.zookeeper.RegistrationHolder
            dup
            aload 3 /* v */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.servicediscovery.Record
            aload 1
            invokespecial io.vertx.servicediscovery.zookeeper.RegistrationHolder.<init>:(Lio/vertx/servicediscovery/Record;Ljava/lang/Object;)V
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         2: .line 151
            aload 2
            aconst_null
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         3: .line 152
            goto 5
         4: .line 153
      StackMap locals:
      StackMap stack:
            aload 2
            aload 3 /* v */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         5: .line 155
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.AsyncResult v
        end local 0 // io.vertx.servicediscovery.zookeeper.ZookeeperServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter;
            0    6     3     v  Lio/vertx/core/AsyncResult<Lio/vertx/servicediscovery/Record;>;
}
SourceFile: "ZookeeperServiceImporter.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public Builder = org.apache.curator.framework.CuratorFrameworkFactory$Builder of org.apache.curator.framework.CuratorFrameworkFactory
  public final Builder = org.apache.curator.framework.recipes.cache.TreeCache$Builder of org.apache.curator.framework.recipes.cache.TreeCache
  public final Type = org.apache.curator.framework.recipes.cache.TreeCacheEvent$Type of org.apache.curator.framework.recipes.cache.TreeCacheEvent
  public NoNodeException = org.apache.zookeeper.KeeperException$NoNodeException of org.apache.zookeeper.KeeperException
/

io.vertx/ vertx-service-discovery-bridge-zookeeper/ 4.0.0/ io/vertx/servicediscovery/zookeeper/ZookeeperServiceImporter.class
