io.vertx/vertx-service-discovery-bridge-docker/3.8.0 : io/vertx/servicediscovery/docker/DockerServiceImporter.class

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

  private long timer;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  private com.github.dockerjava.api.DockerClient client;
    descriptor: Lcom/github/dockerjava/api/DockerClient;
    flags: (0x0002) ACC_PRIVATE

  private java.util.List<io.vertx.servicediscovery.docker.DockerService> services;
    descriptor: Ljava/util/List;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/List<Lio/vertx/servicediscovery/docker/DockerService;>;

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

  private io.vertx.core.Vertx vertx;
    descriptor: Lio/vertx/core/Vertx;
    flags: (0x0002) ACC_PRIVATE

  private java.lang.String host;
    descriptor: Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE

  volatile boolean started;
    descriptor: Z
    flags: (0x0040) ACC_VOLATILE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 48
            ldc Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
            putstatic io.vertx.servicediscovery.docker.DockerServiceImporter.LOGGER:Lio/vertx/core/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.docker.DockerServiceImporter this
         0: .line 46
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 53
            aload 0 /* this */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.services:Ljava/util/List;
         2: .line 46
            return
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;

  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=5, locals=18, args_size=5
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter 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 completion
         0: .line 70
            aload 0 /* this */
            aload 2 /* publisher */
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
         1: .line 71
            aload 0 /* this */
            aload 1 /* vertx */
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.vertx:Lio/vertx/core/Vertx;
         2: .line 73
            invokestatic com.github.dockerjava.core.DockerClientConfig.createDefaultConfigBuilder:()Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
         3: .line 72
            astore 5 /* builder */
        start local 5 // com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder builder
         4: .line 74
            aload 3 /* configuration */
            ldc "docker-cert-path"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 6 /* dockerCertPath */
        start local 6 // java.lang.String dockerCertPath
         5: .line 75
            aload 3 /* configuration */
            ldc "docker-cfg-path"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 7 /* dockerCfgPath */
        start local 7 // java.lang.String dockerCfgPath
         6: .line 76
            aload 3 /* configuration */
            ldc "docker-registry-email"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 8 /* email */
        start local 8 // java.lang.String email
         7: .line 77
            aload 3 /* configuration */
            ldc "docker-registry-password"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 9 /* password */
        start local 9 // java.lang.String password
         8: .line 78
            aload 3 /* configuration */
            ldc "docker-registry-username"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 10 /* username */
        start local 10 // java.lang.String username
         9: .line 79
            aload 3 /* configuration */
            ldc "docker-host"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 11 /* host */
        start local 11 // java.lang.String host
        10: .line 80
            aload 3 /* configuration */
            ldc "docker-tls-verify"
            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 12 /* tlsVerify */
        start local 12 // boolean tlsVerify
        11: .line 82
            aload 3 /* configuration */
            ldc "docker-registry-url"
            ldc "https://index.docker.io/v1/"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
        12: .line 81
            astore 13 /* registry */
        start local 13 // java.lang.String registry
        13: .line 83
            aload 3 /* configuration */
            ldc "version"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 14 /* version */
        start local 14 // java.lang.String version
        14: .line 85
            aload 6 /* dockerCertPath */
            ifnull 16
        15: .line 86
            aload 5 /* builder */
            aload 6 /* dockerCertPath */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withDockerCertPath:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        16: .line 88
      StackMap locals: io.vertx.servicediscovery.docker.DockerServiceImporter io.vertx.core.Vertx io.vertx.servicediscovery.spi.ServicePublisher io.vertx.core.json.JsonObject io.vertx.core.Promise com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder java.lang.String java.lang.String java.lang.String java.lang.String java.lang.String java.lang.String int java.lang.String java.lang.String
      StackMap stack:
            aload 7 /* dockerCfgPath */
            ifnull 18
        17: .line 89
            aload 5 /* builder */
            aload 7 /* dockerCfgPath */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withDockerConfig:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        18: .line 91
      StackMap locals:
      StackMap stack:
            aload 8 /* email */
            ifnull 20
        19: .line 92
            aload 5 /* builder */
            aload 8 /* email */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withRegistryEmail:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        20: .line 94
      StackMap locals:
      StackMap stack:
            aload 9 /* password */
            ifnull 22
        21: .line 95
            aload 5 /* builder */
            aload 9 /* password */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withRegistryPassword:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        22: .line 97
      StackMap locals:
      StackMap stack:
            aload 10 /* username */
            ifnull 24
        23: .line 98
            aload 5 /* builder */
            aload 10 /* username */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withRegistryUsername:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        24: .line 100
      StackMap locals:
      StackMap stack:
            aload 11 /* host */
            ifnull 26
        25: .line 101
            aload 5 /* builder */
            aload 11 /* host */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withDockerHost:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        26: .line 103
      StackMap locals:
      StackMap stack:
            aload 13 /* registry */
            ifnull 28
        27: .line 104
            aload 5 /* builder */
            aload 13 /* registry */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withRegistryUrl:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        28: .line 106
      StackMap locals:
      StackMap stack:
            aload 14 /* version */
            ifnull 30
        29: .line 107
            aload 5 /* builder */
            aload 14 /* version */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withApiVersion:(Ljava/lang/String;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        30: .line 109
      StackMap locals:
      StackMap stack:
            aload 5 /* builder */
            iload 12 /* tlsVerify */
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.withDockerTlsVerify:(Ljava/lang/Boolean;)Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            pop
        31: .line 112
            aload 5 /* builder */
            invokevirtual com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder.build:()Lcom/github/dockerjava/core/DockerClientConfig;
            astore 15 /* config */
        start local 15 // com.github.dockerjava.core.DockerClientConfig config
        32: .line 113
            aload 15 /* config */
            invokevirtual com.github.dockerjava.core.DockerClientConfig.getDockerHost:()Ljava/net/URI;
            invokevirtual java.net.URI.getScheme:()Ljava/lang/String;
            ldc "unix"
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 38
        33: .line 115
            aload 0 /* this */
            invokestatic java.net.InetAddress.getLocalHost:()Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.getHostAddress:()Ljava/lang/String;
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.host:Ljava/lang/String;
        34: .line 116
            goto 39
      StackMap locals: io.vertx.servicediscovery.docker.DockerServiceImporter io.vertx.core.Vertx io.vertx.servicediscovery.spi.ServicePublisher io.vertx.core.json.JsonObject io.vertx.core.Promise com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder java.lang.String java.lang.String java.lang.String java.lang.String java.lang.String java.lang.String int java.lang.String java.lang.String com.github.dockerjava.core.DockerClientConfig
      StackMap stack: java.net.UnknownHostException
        35: astore 16 /* e */
        start local 16 // java.net.UnknownHostException e
        36: .line 117
            aload 4 /* completion */
            aload 16 /* e */
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
        end local 16 // java.net.UnknownHostException e
        37: .line 119
            goto 39
        38: .line 120
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 15 /* config */
            invokevirtual com.github.dockerjava.core.DockerClientConfig.getDockerHost:()Ljava/net/URI;
            invokevirtual java.net.URI.getHost:()Ljava/lang/String;
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.host:Ljava/lang/String;
        39: .line 122
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 15 /* config */
            invokestatic com.github.dockerjava.core.DockerClientBuilder.getInstance:(Lcom/github/dockerjava/core/DockerClientConfig;)Lcom/github/dockerjava/core/DockerClientBuilder;
            invokevirtual com.github.dockerjava.core.DockerClientBuilder.build:()Lcom/github/dockerjava/api/DockerClient;
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.client:Lcom/github/dockerjava/api/DockerClient;
        40: .line 124
            aload 3 /* configuration */
            ldc "scan-period"
            ldc 3000
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokevirtual io.vertx.core.json.JsonObject.getLong:(Ljava/lang/String;Ljava/lang/Long;)Ljava/lang/Long;
            invokevirtual java.lang.Long.longValue:()J
            lstore 16 /* period */
        start local 16 // long period
        41: .line 125
            lload 16 /* period */
            lconst_0
            lcmp
            ifle 43
        42: .line 126
            aload 0 /* this */
            aload 1 /* vertx */
            lload 16 /* period */
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/servicediscovery/docker/DockerServiceImporter;)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/docker/DockerServiceImporter.lambda$0(Ljava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setPeriodic:(JLio/vertx/core/Handler;)J
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.timer:J
        43: .line 130
      StackMap locals: long
      StackMap stack:
            aload 0 /* this */
            aload 4 /* completion */
            invokevirtual io.vertx.servicediscovery.docker.DockerServiceImporter.scan:(Lio/vertx/core/Promise;)V
        44: .line 131
            return
        end local 16 // long period
        end local 15 // com.github.dockerjava.core.DockerClientConfig config
        end local 14 // java.lang.String version
        end local 13 // java.lang.String registry
        end local 12 // boolean tlsVerify
        end local 11 // java.lang.String host
        end local 10 // java.lang.String username
        end local 9 // java.lang.String password
        end local 8 // java.lang.String email
        end local 7 // java.lang.String dockerCfgPath
        end local 6 // java.lang.String dockerCertPath
        end local 5 // com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder builder
        end local 4 // io.vertx.core.Promise completion
        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.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   45     0            this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0   45     1           vertx  Lio/vertx/core/Vertx;
            0   45     2       publisher  Lio/vertx/servicediscovery/spi/ServicePublisher;
            0   45     3   configuration  Lio/vertx/core/json/JsonObject;
            0   45     4      completion  Lio/vertx/core/Promise<Ljava/lang/Void;>;
            4   45     5         builder  Lcom/github/dockerjava/core/DockerClientConfig$DockerClientConfigBuilder;
            5   45     6  dockerCertPath  Ljava/lang/String;
            6   45     7   dockerCfgPath  Ljava/lang/String;
            7   45     8           email  Ljava/lang/String;
            8   45     9        password  Ljava/lang/String;
            9   45    10        username  Ljava/lang/String;
           10   45    11            host  Ljava/lang/String;
           11   45    12       tlsVerify  Z
           13   45    13        registry  Ljava/lang/String;
           14   45    14         version  Ljava/lang/String;
           32   45    15          config  Lcom/github/dockerjava/core/DockerClientConfig;
           36   37    16               e  Ljava/net/UnknownHostException;
           41   45    16          period  J
      Exception table:
        from    to  target  type
          33    34      35  Class java.net.UnknownHostException
    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  
      completion     

  synchronized void scan(io.vertx.core.Promise<java.lang.Void>);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // io.vertx.core.Promise completion
         0: .line 134
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.vertx:Lio/vertx/core/Vertx;
         1: .line 135
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/servicediscovery/docker/DockerServiceImporter;)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/docker/DockerServiceImporter.lambda$1(Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
         2: .line 142
            aload 0 /* this */
            aload 1 /* completion */
            invokedynamic handle(Lio/vertx/servicediscovery/docker/DockerServiceImporter;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/docker/DockerServiceImporter.lambda$2(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
         3: .line 134
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
         4: .line 182
            return
        end local 1 // io.vertx.core.Promise completion
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    5     1  completion  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
    MethodParameters:
            Name  Flags
      completion  

  private void publish(io.vertx.servicediscovery.docker.DockerService);
    descriptor: (Lio/vertx/servicediscovery/docker/DockerService;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // io.vertx.servicediscovery.docker.DockerService service
         0: .line 185
            aload 1 /* service */
            invokevirtual io.vertx.servicediscovery.docker.DockerService.records:()Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 3
      StackMap locals: io.vertx.servicediscovery.docker.DockerServiceImporter io.vertx.servicediscovery.docker.DockerService top java.util.Iterator
      StackMap stack:
         1: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.servicediscovery.Record
            astore 2 /* record */
        start local 2 // io.vertx.servicediscovery.Record record
         2: .line 186
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aload 2 /* record */
            aload 2 /* record */
            aload 1 /* service */
            invokedynamic handle(Lio/vertx/servicediscovery/Record;Lio/vertx/servicediscovery/docker/DockerService;)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/docker/DockerServiceImporter.lambda$7(Lio/vertx/servicediscovery/Record;Lio/vertx/servicediscovery/docker/DockerService;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.servicediscovery.spi.ServicePublisher.publish:(Lio/vertx/servicediscovery/Record;Lio/vertx/core/Handler;)V
        end local 2 // io.vertx.servicediscovery.Record record
         3: .line 185
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         4: .line 197
            return
        end local 1 // io.vertx.servicediscovery.docker.DockerService service
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    5     1  service  Lio/vertx/servicediscovery/docker/DockerService;
            2    3     2   record  Lio/vertx/servicediscovery/Record;
    MethodParameters:
         Name  Flags
      service  

  private void unpublish(io.vertx.servicediscovery.docker.DockerService);
    descriptor: (Lio/vertx/servicediscovery/docker/DockerService;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // io.vertx.servicediscovery.docker.DockerService service
         0: .line 200
            aload 1 /* service */
            invokevirtual io.vertx.servicediscovery.docker.DockerService.records:()Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 3
      StackMap locals: io.vertx.servicediscovery.docker.DockerServiceImporter io.vertx.servicediscovery.docker.DockerService top java.util.Iterator
      StackMap stack:
         1: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.servicediscovery.Record
            astore 2 /* record */
        start local 2 // io.vertx.servicediscovery.Record record
         2: .line 201
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aload 2 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getRegistration:()Ljava/lang/String;
            aload 1 /* service */
            aload 2 /* record */
            invokedynamic handle(Lio/vertx/servicediscovery/docker/DockerService;Lio/vertx/servicediscovery/Record;)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/docker/DockerServiceImporter.lambda$8(Lio/vertx/servicediscovery/docker/DockerService;Lio/vertx/servicediscovery/Record;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.servicediscovery.spi.ServicePublisher.unpublish:(Ljava/lang/String;Lio/vertx/core/Handler;)V
        end local 2 // io.vertx.servicediscovery.Record record
         3: .line 200
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         4: .line 206
            return
        end local 1 // io.vertx.servicediscovery.docker.DockerService service
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    5     1  service  Lio/vertx/servicediscovery/docker/DockerService;
            2    3     2   record  Lio/vertx/servicediscovery/Record;
    MethodParameters:
         Name  Flags
      service  

  private boolean isKnown(com.github.dockerjava.api.model.Container);
    descriptor: (Lcom/github/dockerjava/api/model/Container;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // com.github.dockerjava.api.model.Container container
         0: .line 209
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.services:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 4
      StackMap locals: io.vertx.servicediscovery.docker.DockerServiceImporter com.github.dockerjava.api.model.Container top java.util.Iterator
      StackMap stack:
         1: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.servicediscovery.docker.DockerService
            astore 2 /* service */
        start local 2 // io.vertx.servicediscovery.docker.DockerService service
         2: .line 210
            aload 2 /* service */
            invokevirtual io.vertx.servicediscovery.docker.DockerService.id:()Ljava/lang/String;
            aload 1 /* container */
            invokevirtual com.github.dockerjava.api.model.Container.getId:()Ljava/lang/String;
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 4
         3: .line 211
            iconst_1
            ireturn
        end local 2 // io.vertx.servicediscovery.docker.DockerService service
         4: .line 209
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         5: .line 214
            iconst_0
            ireturn
        end local 1 // com.github.dockerjava.api.model.Container container
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     0       this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    6     1  container  Lcom/github/dockerjava/api/model/Container;
            2    4     2    service  Lio/vertx/servicediscovery/docker/DockerService;
    MethodParameters:
           Name  Flags
      container  

  private boolean isNotRunning(java.lang.String, java.util.List<com.github.dockerjava.api.model.Container>);
    descriptor: (Ljava/lang/String;Ljava/util/List;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=5, args_size=3
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // java.lang.String containerId
        start local 2 // java.util.List running
         0: .line 218
            aload 2 /* running */
            ifnonnull 2
         1: .line 220
            iconst_1
            ireturn
         2: .line 223
      StackMap locals:
      StackMap stack:
            aload 2 /* running */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 4
            goto 6
      StackMap locals: io.vertx.servicediscovery.docker.DockerServiceImporter java.lang.String java.util.List top java.util.Iterator
      StackMap stack:
         3: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.github.dockerjava.api.model.Container
            astore 3 /* container */
        start local 3 // com.github.dockerjava.api.model.Container container
         4: .line 224
            aload 3 /* container */
            invokevirtual com.github.dockerjava.api.model.Container.getId:()Ljava/lang/String;
            aload 1 /* containerId */
            invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
            ifeq 6
         5: .line 226
            iconst_0
            ireturn
        end local 3 // com.github.dockerjava.api.model.Container container
         6: .line 223
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         7: .line 231
            iconst_1
            ireturn
        end local 2 // java.util.List running
        end local 1 // java.lang.String containerId
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0         this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    8     1  containerId  Ljava/lang/String;
            0    8     2      running  Ljava/util/List<Lcom/github/dockerjava/api/model/Container;>;
            4    6     3    container  Lcom/github/dockerjava/api/model/Container;
    Signature: (Ljava/lang/String;Ljava/util/List<Lcom/github/dockerjava/api/model/Container;>;)Z
    MethodParameters:
             Name  Flags
      containerId  
      running      

  public void close(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // io.vertx.core.Handler completionHandler
         0: .line 236
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.timer:J
            invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
            pop
         1: .line 238
            aload 0 /* this */
            iconst_0
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.started:Z
         2: .line 239
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.client:Lcom/github/dockerjava/api/DockerClient;
            invokeinterface com.github.dockerjava.api.DockerClient.close:()V
         3: .line 240
            getstatic io.vertx.servicediscovery.docker.DockerServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Successfully closed the service importer "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
         4: .line 241
            goto 7
      StackMap locals:
      StackMap stack: java.io.IOException
         5: astore 2 /* e */
        start local 2 // java.io.IOException e
         6: .line 242
            getstatic io.vertx.servicediscovery.docker.DockerServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "A failure has been caught while stopping "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 2 /* e */
            invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        end local 2 // java.io.IOException e
         7: .line 244
      StackMap locals:
      StackMap stack:
            aload 1 /* completionHandler */
            ifnull 9
         8: .line 245
            aload 1 /* completionHandler */
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         9: .line 247
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Handler completionHandler
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   10     0               this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0   10     1  completionHandler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
            6    7     2                  e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           1     4       5  Class java.io.IOException
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  

  synchronized java.util.List<io.vertx.servicediscovery.docker.DockerService> getServices();
    descriptor: ()Ljava/util/List;
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
         0: .line 250
            new java.util.ArrayList
            dup
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.services:Ljava/util/List;
            invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
            areturn
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
    Signature: ()Ljava/util/List<Lio/vertx/servicediscovery/docker/DockerService;>;

  private void lambda$0(java.lang.Long);
    descriptor: (Ljava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // java.lang.Long l
         0: .line 127
            aload 0 /* this */
            aconst_null
            invokevirtual io.vertx.servicediscovery.docker.DockerServiceImporter.scan:(Lio/vertx/core/Promise;)V
         1: .line 128
            return
        end local 1 // java.lang.Long l
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    2     1     l  Ljava/lang/Long;

  private void lambda$1(io.vertx.core.Promise);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // io.vertx.core.Promise future
         0: .line 137
            aload 1 /* future */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.client:Lcom/github/dockerjava/api/DockerClient;
            invokeinterface com.github.dockerjava.api.DockerClient.listContainersCmd:()Lcom/github/dockerjava/api/command/ListContainersCmd;
            ldc "running"
            invokeinterface com.github.dockerjava.api.command.ListContainersCmd.withStatusFilter:(Ljava/lang/String;)Lcom/github/dockerjava/api/command/ListContainersCmd;
            invokeinterface com.github.dockerjava.api.command.ListContainersCmd.exec:()Ljava/lang/Object;
            checkcast java.util.List
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         1: .line 138
            goto 4
      StackMap locals:
      StackMap stack: java.lang.Exception
         2: astore 2 /* e */
        start local 2 // java.lang.Exception e
         3: .line 139
            aload 1 /* future */
            aload 2 /* e */
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
        end local 2 // java.lang.Exception e
         4: .line 141
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Promise future
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    5     1  future  Lio/vertx/core/Promise<Ljava/util/List<Lcom/github/dockerjava/api/model/Container;>;>;
            3    4     2       e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.Exception

  private void lambda$2(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=3, locals=5, args_size=3
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 143
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 6
         1: .line 144
            aload 1
            ifnull 4
         2: .line 145
            aload 1
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         3: .line 146
            goto 5
         4: .line 147
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.servicediscovery.docker.DockerServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
            ldc "Fail to import services from docker"
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         5: .line 149
      StackMap locals:
      StackMap stack:
            return
         6: .line 151
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.vertx.servicediscovery.docker.DockerServiceImporter.started:Z
         7: .line 152
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.List
            astore 3 /* running */
        start local 3 // java.util.List running
         8: .line 153
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 4 /* toRemove */
        start local 4 // java.util.List toRemove
         9: .line 156
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.services:Ljava/util/List;
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
        10: .line 157
            aload 0 /* this */
            aload 3 /* running */
            invokedynamic test(Lio/vertx/servicediscovery/docker/DockerServiceImporter;Ljava/util/List;)Ljava/util/function/Predicate;
              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;)Z
                  io/vertx/servicediscovery/docker/DockerServiceImporter.lambda$3(Ljava/util/List;Lio/vertx/servicediscovery/docker/DockerService;)Z (7)
                  (Lio/vertx/servicediscovery/docker/DockerService;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
        11: .line 158
            aload 0 /* this */
            aload 4 /* toRemove */
            invokedynamic accept(Lio/vertx/servicediscovery/docker/DockerServiceImporter;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
                  io/vertx/servicediscovery/docker/DockerServiceImporter.lambda$4(Ljava/util/List;Lio/vertx/servicediscovery/docker/DockerService;)V (7)
                  (Lio/vertx/servicediscovery/docker/DockerService;)V
            invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
        12: .line 162
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.services:Ljava/util/List;
            aload 4 /* toRemove */
            invokeinterface java.util.List.removeAll:(Ljava/util/Collection;)Z
            pop
        13: .line 164
            aload 3 /* running */
            ifnull 17
        14: .line 166
            aload 3 /* running */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
        15: .line 167
            aload 0 /* this */
            invokedynamic test(Lio/vertx/servicediscovery/docker/DockerServiceImporter;)Ljava/util/function/Predicate;
              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;)Z
                  io/vertx/servicediscovery/docker/DockerServiceImporter.lambda$5(Lcom/github/dockerjava/api/model/Container;)Z (7)
                  (Lcom/github/dockerjava/api/model/Container;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
        16: .line 168
            aload 0 /* this */
            invokedynamic accept(Lio/vertx/servicediscovery/docker/DockerServiceImporter;)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/docker/DockerServiceImporter.lambda$6(Lcom/github/dockerjava/api/model/Container;)V (7)
                  (Lcom/github/dockerjava/api/model/Container;)V
            invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
        17: .line 177
      StackMap locals: java.util.List java.util.List
      StackMap stack:
            aload 1
            ifnull 19
        18: .line 178
            aload 1
            invokeinterface io.vertx.core.Promise.complete:()V
        end local 4 // java.util.List toRemove
        end local 3 // java.util.List running
        19: .line 180
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   20     0      this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0   20     2        ar  Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/github/dockerjava/api/model/Container;>;>;
            8   19     3   running  Ljava/util/List<Lcom/github/dockerjava/api/model/Container;>;
            9   19     4  toRemove  Ljava/util/List<Lio/vertx/servicediscovery/docker/DockerService;>;

  private static void lambda$7(io.vertx.servicediscovery.Record, io.vertx.servicediscovery.docker.DockerService, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/servicediscovery/Record;Lio/vertx/servicediscovery/docker/DockerService;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 187
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 6
         1: .line 188
            aload 0
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.servicediscovery.Record
            invokevirtual io.vertx.servicediscovery.Record.getRegistration:()Ljava/lang/String;
            invokevirtual io.vertx.servicediscovery.Record.setRegistration:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
            pop
         2: .line 189
            getstatic io.vertx.servicediscovery.docker.DockerServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Service from container "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1
            invokevirtual io.vertx.servicediscovery.docker.DockerService.id:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " on location "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         3: .line 190
            aload 0
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc " has been published"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 189
            invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
         5: .line 191
            goto 9
         6: .line 192
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.servicediscovery.docker.DockerServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Service from container "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1
            invokevirtual io.vertx.servicediscovery.docker.DockerService.id:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " on location "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         7: .line 193
            aload 0
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc " could not have been published"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
         8: .line 192
            invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         9: .line 195
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     2    ar  Lio/vertx/core/AsyncResult<Lio/vertx/servicediscovery/Record;>;

  private static void lambda$8(io.vertx.servicediscovery.docker.DockerService, io.vertx.servicediscovery.Record, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/servicediscovery/docker/DockerService;Lio/vertx/servicediscovery/Record;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 202
            getstatic io.vertx.servicediscovery.docker.DockerServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Service from container "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0
            invokevirtual io.vertx.servicediscovery.docker.DockerService.id:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         1: .line 203
            ldc " on location "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1
            invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc " has been unpublished"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 202
            invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
         3: .line 204
            return
        end local 2 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     2    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private boolean lambda$3(java.util.List, io.vertx.servicediscovery.docker.DockerService);
    descriptor: (Ljava/util/List;Lio/vertx/servicediscovery/docker/DockerService;)Z
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 2 // io.vertx.servicediscovery.docker.DockerService service
         0: .line 157
            aload 0 /* this */
            aload 2 /* service */
            invokevirtual io.vertx.servicediscovery.docker.DockerService.id:()Ljava/lang/String;
            aload 1
            invokevirtual io.vertx.servicediscovery.docker.DockerServiceImporter.isNotRunning:(Ljava/lang/String;Ljava/util/List;)Z
            ireturn
        end local 2 // io.vertx.servicediscovery.docker.DockerService service
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    1     2  service  Lio/vertx/servicediscovery/docker/DockerService;

  private void lambda$4(java.util.List, io.vertx.servicediscovery.docker.DockerService);
    descriptor: (Ljava/util/List;Lio/vertx/servicediscovery/docker/DockerService;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 2 // io.vertx.servicediscovery.docker.DockerService service
         0: .line 159
            aload 0 /* this */
            aload 2 /* service */
            invokevirtual io.vertx.servicediscovery.docker.DockerServiceImporter.unpublish:(Lio/vertx/servicediscovery/docker/DockerService;)V
         1: .line 160
            aload 1
            aload 2 /* service */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         2: .line 161
            return
        end local 2 // io.vertx.servicediscovery.docker.DockerService service
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    3     2  service  Lio/vertx/servicediscovery/docker/DockerService;

  private boolean lambda$5(com.github.dockerjava.api.model.Container);
    descriptor: (Lcom/github/dockerjava/api/model/Container;)Z
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // com.github.dockerjava.api.model.Container container
         0: .line 167
            aload 0 /* this */
            aload 1 /* container */
            invokevirtual io.vertx.servicediscovery.docker.DockerServiceImporter.isKnown:(Lcom/github/dockerjava/api/model/Container;)Z
            ifeq 1
            iconst_0
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_1
      StackMap locals:
      StackMap stack: int
         2: ireturn
        end local 1 // com.github.dockerjava.api.model.Container container
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    3     1  container  Lcom/github/dockerjava/api/model/Container;

  private void lambda$6(com.github.dockerjava.api.model.Container);
    descriptor: (Lcom/github/dockerjava/api/model/Container;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
        start local 1 // com.github.dockerjava.api.model.Container container
         0: .line 169
            new io.vertx.servicediscovery.docker.DockerService
            dup
            aload 1 /* container */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.host:Ljava/lang/String;
            invokespecial io.vertx.servicediscovery.docker.DockerService.<init>:(Lcom/github/dockerjava/api/model/Container;Ljava/lang/String;)V
            astore 2 /* service */
        start local 2 // io.vertx.servicediscovery.docker.DockerService service
         1: .line 170
            aload 2 /* service */
            invokevirtual io.vertx.servicediscovery.docker.DockerService.records:()Ljava/util/List;
            invokeinterface java.util.List.isEmpty:()Z
            ifne 4
         2: .line 171
            aload 0 /* this */
            getfield io.vertx.servicediscovery.docker.DockerServiceImporter.services:Ljava/util/List;
            aload 2 /* service */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         3: .line 172
            aload 0 /* this */
            aload 2 /* service */
            invokevirtual io.vertx.servicediscovery.docker.DockerServiceImporter.publish:(Lio/vertx/servicediscovery/docker/DockerService;)V
        end local 2 // io.vertx.servicediscovery.docker.DockerService service
         4: .line 174
      StackMap locals:
      StackMap stack:
            return
        end local 1 // com.github.dockerjava.api.model.Container container
        end local 0 // io.vertx.servicediscovery.docker.DockerServiceImporter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0       this  Lio/vertx/servicediscovery/docker/DockerServiceImporter;
            0    5     1  container  Lcom/github/dockerjava/api/model/Container;
            1    4     2    service  Lio/vertx/servicediscovery/docker/DockerService;
}
SourceFile: "DockerServiceImporter.java"
InnerClasses:
  public DockerClientConfigBuilder = com.github.dockerjava.core.DockerClientConfig$DockerClientConfigBuilder of com.github.dockerjava.core.DockerClientConfig
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
/

io.vertx/ vertx-service-discovery-bridge-docker/ 3.8.0/ io/vertx/servicediscovery/docker/DockerServiceImporter.class
