public class io.vertx.servicediscovery.docker.DockerLinksServiceImporter 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.DockerLinksServiceImporter
super_class: java.lang.Object
{
private io.vertx.servicediscovery.spi.ServicePublisher publisher;
descriptor: Lio/vertx/servicediscovery/spi/ServicePublisher;
flags: (0x0002) ACC_PRIVATE
private java.util.List<io.vertx.servicediscovery.Record> records;
descriptor: Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/List<Lio/vertx/servicediscovery/Record;>;
private static final io.vertx.core.logging.Logger LOGGER;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.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 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield io.vertx.servicediscovery.docker.DockerLinksServiceImporter.records:Ljava/util/List;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
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=2, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 2
putfield io.vertx.servicediscovery.docker.DockerLinksServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
1: aload 0
dup
astore 5
monitorenter
2: aload 0
aload 4
invokevirtual io.vertx.servicediscovery.docker.DockerLinksServiceImporter.lookup:(Lio/vertx/core/Promise;)V
3: aload 5
monitorexit
4: goto 7
StackMap locals: io.vertx.servicediscovery.docker.DockerLinksServiceImporter io.vertx.core.Vertx io.vertx.servicediscovery.spi.ServicePublisher io.vertx.core.json.JsonObject io.vertx.core.Promise io.vertx.servicediscovery.docker.DockerLinksServiceImporter
StackMap stack: java.lang.Throwable
5: aload 5
monitorexit
6: athrow
7: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 8 1 vertx Lio/vertx/core/Vertx;
0 8 2 publisher Lio/vertx/servicediscovery/spi/ServicePublisher;
0 8 3 configuration Lio/vertx/core/json/JsonObject;
0 8 4 completion Lio/vertx/core/Promise<Ljava/lang/Void;>;
Exception table:
from to target type
2 4 5 any
5 6 5 any
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
private void lookup(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=7, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.servicediscovery.docker.DockerLinksServiceImporter.getVariables:()Ljava/util/Map;
astore 2
start local 2 1: aload 2
invokeinterface java.util.Map.keySet:()Ljava/util/Set;
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
2: invokedynamic test()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/DockerLinksServiceImporter.lambda$0(Ljava/lang/String;)Z (6)
(Ljava/lang/String;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
3: aload 0
aload 2
invokedynamic apply(Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;Ljava/util/Map;)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/docker/DockerLinksServiceImporter.lambda$1(Ljava/util/Map;Ljava/lang/String;)Ljava/lang/String; (7)
(Ljava/lang/String;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
4: invokedynamic test()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/DockerLinksServiceImporter.lambda$2(Ljava/lang/String;)Z (6)
(Ljava/lang/String;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
5: invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
6: astore 3
start local 3 7: getstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Docker links: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
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
8: aload 3
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 23
StackMap locals: io.vertx.servicediscovery.docker.DockerLinksServiceImporter io.vertx.core.Promise java.util.Map java.util.List top java.util.Iterator
StackMap stack:
9: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 4
start local 4 10: aload 0
aload 4
11: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
12: aload 4
invokedynamic test(Ljava/lang/String;)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/DockerLinksServiceImporter.lambda$3(Ljava/lang/String;Ljava/util/Map$Entry;)Z (6)
(Ljava/util/Map$Entry;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
13: invokedynamic apply()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;
java/util/Map$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/String;
invokedynamic apply()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;
java/util/Map$Entry.getValue()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/String;
invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
14: invokevirtual io.vertx.servicediscovery.docker.DockerLinksServiceImporter.createRecord:(Ljava/lang/String;Ljava/util/Map;)Lio/vertx/servicediscovery/Record;
astore 6
start local 6 15: getstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Record created from link "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " : "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 6
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
16: aload 0
getfield io.vertx.servicediscovery.docker.DockerLinksServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
aload 6
aload 0
aload 4
invokedynamic handle(Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;Ljava/lang/String;)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/DockerLinksServiceImporter.lambda$6(Ljava/lang/String;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
end local 6 17: goto 23
StackMap locals: io.vertx.servicediscovery.docker.DockerLinksServiceImporter io.vertx.core.Promise java.util.Map java.util.List java.lang.String java.util.Iterator
StackMap stack: java.net.URISyntaxException
18: astore 6
start local 6 19: aload 1
ifnull 22
20: aload 1
aload 6
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
21: goto 23
22: StackMap locals: java.net.URISyntaxException
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Cannot extract service record from variables for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 6
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 6 end local 4 23: StackMap locals: io.vertx.servicediscovery.docker.DockerLinksServiceImporter io.vertx.core.Promise java.util.Map java.util.List top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
24: aload 1
ifnull 26
25: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
26: StackMap locals: io.vertx.servicediscovery.docker.DockerLinksServiceImporter io.vertx.core.Promise java.util.Map java.util.List
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 27 1 completion Lio/vertx/core/Promise<Ljava/lang/Void;>;
1 27 2 variables Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
7 27 3 links Ljava/util/List<Ljava/lang/String;>;
10 23 4 link Ljava/lang/String;
15 17 6 record Lio/vertx/servicediscovery/Record;
19 23 6 e Ljava/net/URISyntaxException;
Exception table:
from to target type
10 17 18 Class java.net.URISyntaxException
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
completion
private java.lang.String extractLinkName(java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Map;)Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
iconst_0
aload 1
invokevirtual java.lang.String.length:()I
ldc "_NAME"
invokevirtual java.lang.String.length:()I
isub
invokevirtual java.lang.String.substring:(II)Ljava/lang/String;
astore 3
start local 3 1: aload 3
invokevirtual java.lang.String.isEmpty:()Z
ifeq 3
2: aconst_null
areturn
3: StackMap locals: java.lang.String
StackMap stack:
new java.lang.StringBuilder
dup
aload 3
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "_PORT"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 4
start local 4 4: aload 2
aload 4
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 6
5: aload 3
areturn
6: StackMap locals: java.lang.String
StackMap stack:
aconst_null
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 7 1 key Ljava/lang/String;
0 7 2 variables Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
1 7 3 name Ljava/lang/String;
4 7 4 port Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Ljava/lang/String;
MethodParameters:
Name Flags
key
variables
private java.util.Map<java.lang.String, java.lang.String> getVariables();
descriptor: ()Ljava/util/Map;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: new java.util.LinkedHashMap
dup
invokespecial java.util.LinkedHashMap.<init>:()V
astore 1
start local 1 1: aload 1
invokestatic java.lang.System.getenv:()Ljava/util/Map;
invokevirtual java.util.LinkedHashMap.putAll:(Ljava/util/Map;)V
2: invokestatic java.lang.System.getProperties:()Ljava/util/Properties;
invokevirtual java.util.Properties.entrySet:()Ljava/util/Set;
aload 1
invokedynamic accept(Ljava/util/LinkedHashMap;)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/DockerLinksServiceImporter.lambda$7(Ljava/util/LinkedHashMap;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
3: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
1 4 1 vars Ljava/util/LinkedHashMap<Ljava/lang/String;Ljava/lang/String;>;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public void close(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 1: aload 0
getfield io.vertx.servicediscovery.docker.DockerLinksServiceImporter.records:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 6
StackMap locals: io.vertx.servicediscovery.docker.DockerLinksServiceImporter io.vertx.core.Handler java.util.List top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.servicediscovery.Record
astore 3
start local 3 3: aload 0
getfield io.vertx.servicediscovery.docker.DockerLinksServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
aload 3
invokevirtual io.vertx.servicediscovery.Record.getRegistration:()Ljava/lang/String;
4: aload 2
invokedynamic handle(Ljava/util/List;)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/DockerLinksServiceImporter.lambda$8(Ljava/util/List;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
5: invokeinterface io.vertx.servicediscovery.spi.ServicePublisher.unpublish:(Ljava/lang/String;Lio/vertx/core/Handler;)V
end local 3 6: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
7: aload 2
invokestatic io.vertx.core.CompositeFuture.all:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
aload 0
aload 1
invokedynamic handle(Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;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/docker/DockerLinksServiceImporter.lambda$9(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.CompositeFuture.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/CompositeFuture;
pop
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 9 1 completionHandler Lio/vertx/core/Handler<Ljava/lang/Void;>;
1 9 2 list Ljava/util/List<Lio/vertx/core/Future;>;
3 6 3 record Lio/vertx/servicediscovery/Record;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
completionHandler
private io.vertx.servicediscovery.Record createRecord(java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Map;)Lio/vertx/servicediscovery/Record;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=9, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.servicediscovery.Record
dup
invokespecial io.vertx.servicediscovery.Record.<init>:()V
1: aload 1
invokevirtual io.vertx.servicediscovery.Record.setName:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
2: astore 3
start local 3 3: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
aload 1
aload 3
invokedynamic accept(Ljava/lang/String;Lio/vertx/servicediscovery/Record;)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/DockerLinksServiceImporter.lambda$10(Ljava/lang/String;Lio/vertx/servicediscovery/Record;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
4: aload 2
new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "_ENV_SERVICE_TYPE"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 4
start local 4 5: aload 4
ifnonnull 8
6: ldc "unknown"
astore 4
7: goto 9
8: StackMap locals: io.vertx.servicediscovery.Record java.lang.String
StackMap stack:
getstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Service type for "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " : "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
9: StackMap locals:
StackMap stack:
new java.net.URI
dup
aload 2
new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "_PORT"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokespecial java.net.URI.<init>:(Ljava/lang/String;)V
astore 5
start local 5 10: aload 4
dup
astore 6
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 1
826978618: 11
default: 20
}
StackMap locals: java.net.URI java.lang.String
StackMap stack:
11: aload 6
ldc "http-endpoint"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 12
goto 20
12: StackMap locals:
StackMap stack:
new io.vertx.servicediscovery.types.HttpLocation
dup
invokespecial io.vertx.servicediscovery.types.HttpLocation.<init>:()V
astore 7
start local 7 13: aload 7
aload 5
invokevirtual java.net.URI.getHost:()Ljava/lang/String;
invokevirtual io.vertx.servicediscovery.types.HttpLocation.setHost:(Ljava/lang/String;)Lio/vertx/servicediscovery/types/HttpLocation;
pop
14: aload 7
aload 5
invokevirtual java.net.URI.getPort:()I
invokevirtual io.vertx.servicediscovery.types.HttpLocation.setPort:(I)Lio/vertx/servicediscovery/types/HttpLocation;
pop
15: aload 2
new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "_ENV_SSL"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.isTrue:(Ljava/util/Map;Ljava/lang/String;)Z
ifeq 17
16: aload 7
iconst_1
invokevirtual io.vertx.servicediscovery.types.HttpLocation.setSsl:(Z)Lio/vertx/servicediscovery/types/HttpLocation;
pop
17: StackMap locals: io.vertx.servicediscovery.types.HttpLocation
StackMap stack:
aload 3
ldc "http-endpoint"
invokevirtual io.vertx.servicediscovery.Record.setType:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
pop
18: aload 3
aload 7
invokevirtual io.vertx.servicediscovery.types.HttpLocation.toJson:()Lio/vertx/core/json/JsonObject;
invokevirtual io.vertx.servicediscovery.Record.setLocation:(Lio/vertx/core/json/JsonObject;)Lio/vertx/servicediscovery/Record;
pop
19: goto 28
end local 7 20: StackMap locals:
StackMap stack:
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 8
start local 8 21: aload 8
22: ldc "endpoint"
aload 5
invokevirtual java.net.URI.toString:()Ljava/lang/String;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
23: ldc "port"
aload 5
invokevirtual java.net.URI.getPort:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Integer;)Lio/vertx/core/json/JsonObject;
24: ldc "host"
aload 5
invokevirtual java.net.URI.getHost:()Ljava/lang/String;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
25: ldc "proto"
aload 5
invokevirtual java.net.URI.getScheme:()Ljava/lang/String;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
pop
26: aload 3
aload 4
invokevirtual io.vertx.servicediscovery.Record.setType:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
pop
27: aload 3
aload 8
invokevirtual io.vertx.servicediscovery.Record.setLocation:(Lio/vertx/core/json/JsonObject;)Lio/vertx/servicediscovery/Record;
pop
end local 8 28: StackMap locals:
StackMap stack:
aload 3
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 29 1 name Ljava/lang/String;
0 29 2 variables Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
3 29 3 record Lio/vertx/servicediscovery/Record;
5 29 4 type Ljava/lang/String;
10 29 5 url Ljava/net/URI;
13 20 7 http Lio/vertx/servicediscovery/types/HttpLocation;
21 28 8 location Lio/vertx/core/json/JsonObject;
Exceptions:
throws java.net.URISyntaxException
Signature: (Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/servicediscovery/Record;
MethodParameters:
Name Flags
name
variables
private static boolean isTrue(java.util.Map<java.lang.String, java.lang.String>, java.lang.String);
descriptor: (Ljava/util/Map;Ljava/lang/String;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ifnull 1
ldc "true"
aload 0
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 labels Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 2 1 key Ljava/lang/String;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/String;)Z
MethodParameters:
Name Flags
labels
key
private static boolean lambda$0(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
ldc "_NAME"
invokevirtual java.lang.String.endsWith:(Ljava/lang/String;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 key Ljava/lang/String;
private java.lang.String lambda$1(java.util.Map, java.lang.String);
descriptor: (Ljava/util/Map;Ljava/lang/String;)Ljava/lang/String;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 2
aload 1
invokevirtual io.vertx.servicediscovery.docker.DockerLinksServiceImporter.extractLinkName:(Ljava/lang/String;Ljava/util/Map;)Ljava/lang/String;
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 1 2 key Ljava/lang/String;
private static boolean lambda$2(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
ifnull 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 key Ljava/lang/String;
private static boolean lambda$3(java.lang.String, java.util.Map$Entry);
descriptor: (Ljava/lang/String;Ljava/util/Map$Entry;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 1 0: aload 1
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
new java.lang.StringBuilder
dup
aload 0
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;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.lang.String.startsWith:(Ljava/lang/String;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
private void lambda$6(java.lang.String, io.vertx.core.AsyncResult);
descriptor: (Ljava/lang/String;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 6
1: aload 0
getfield io.vertx.servicediscovery.docker.DockerLinksServiceImporter.records:Ljava/util/List;
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.servicediscovery.Record
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
2: getstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Service imported from Docker link : "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " with endpoint set to "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
3: aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.servicediscovery.Record
invokevirtual io.vertx.servicediscovery.Record.getLocation:()Lio/vertx/core/json/JsonObject;
ldc "endpoint"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
5: goto 7
6: StackMap locals:
StackMap stack:
getstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.LOGGER:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Publication of the docker link "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " as a service failed"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
7: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 8 2 ar Lio/vertx/core/AsyncResult<Lio/vertx/servicediscovery/Record;>;
private static void lambda$7(java.util.LinkedHashMap, java.util.Map$Entry);
descriptor: (Ljava/util/LinkedHashMap;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
aload 1
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
invokevirtual java.util.LinkedHashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 entry Ljava/util/Map$Entry<Ljava/lang/Object;Ljava/lang/Object;>;
private static void lambda$8(java.util.List, io.vertx.core.AsyncResult);
descriptor: (Ljava/util/List;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 1
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
goto 2
StackMap locals:
StackMap stack: java.util.List
1: aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
StackMap locals: java.util.List io.vertx.core.AsyncResult
StackMap stack: java.util.List io.vertx.core.Future
2: invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 v Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;
private void lambda$9(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=4, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.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
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
2: goto 4
3: StackMap locals:
StackMap stack:
getstatic io.vertx.servicediscovery.docker.DockerLinksServiceImporter.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
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
aload 1
ifnull 6
5: aload 1
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/servicediscovery/docker/DockerLinksServiceImporter;
0 7 2 ar Lio/vertx/core/AsyncResult<Lio/vertx/core/CompositeFuture;>;
private static void lambda$10(java.lang.String, io.vertx.servicediscovery.Record, java.util.Map$Entry);
descriptor: (Ljava/lang/String;Lio/vertx/servicediscovery/Record;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 2 0: aload 2
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
new java.lang.StringBuilder
dup
aload 0
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;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.lang.String.startsWith:(Ljava/lang/String;)Z
ifeq 3
1: aload 2
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
new java.lang.StringBuilder
dup
aload 0
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;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.lang.String.length:()I
invokevirtual java.lang.String.substring:(I)Ljava/lang/String;
astore 3
start local 3 2: aload 1
invokevirtual io.vertx.servicediscovery.Record.getMetadata:()Lio/vertx/core/json/JsonObject;
aload 3
aload 2
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
pop
end local 3 3: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 4 2 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
2 3 3 label Ljava/lang/String;
}
SourceFile: "DockerLinksServiceImporter.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map