public class io.vertx.spi.cluster.ignite.impl.SubsMapHelper
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.spi.cluster.ignite.impl.SubsMapHelper
super_class: java.lang.Object
{
private static final int[] CACHE_EVENTS;
descriptor: [I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final org.apache.ignite.IgniteCache<io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo, java.lang.Boolean> map;
descriptor: Lorg/apache/ignite/IgniteCache;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/apache/ignite/IgniteCache<Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;>;
private final org.apache.ignite.lang.IgnitePredicate<org.apache.ignite.events.Event> eventListener;
descriptor: Lorg/apache/ignite/lang/IgnitePredicate;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/apache/ignite/lang/IgnitePredicate<Lorg/apache/ignite/events/Event;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: iconst_2
newarray 10
dup
iconst_0
bipush 63
iastore
dup
iconst_1
bipush 65
iastore
putstatic io.vertx.spi.cluster.ignite.impl.SubsMapHelper.CACHE_EVENTS:[I
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.ignite.Ignite, io.vertx.core.spi.cluster.NodeSelector, io.vertx.core.impl.VertxInternal);
descriptor: (Lorg/apache/ignite/Ignite;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
ldc "__vertx.subs"
invokeinterface org.apache.ignite.Ignite.getOrCreateCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
putfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.map:Lorg/apache/ignite/IgniteCache;
2: aload 0
aload 0
aload 2
aload 3
invokedynamic apply(Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;)Lorg/apache/ignite/lang/IgnitePredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/impl/SubsMapHelper.lambda$0(Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;Lorg/apache/ignite/events/Event;)Z (7)
(Lorg/apache/ignite/events/Event;)Z
1
putfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
3: aload 1
invokeinterface org.apache.ignite.Ignite.events:()Lorg/apache/ignite/IgniteEvents;
aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
getstatic io.vertx.spi.cluster.ignite.impl.SubsMapHelper.CACHE_EVENTS:[I
invokeinterface org.apache.ignite.IgniteEvents.localListen:(Lorg/apache/ignite/lang/IgnitePredicate;[I)V
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 5 1 ignite Lorg/apache/ignite/Ignite;
0 5 2 nodeSelector Lio/vertx/core/spi/cluster/NodeSelector;
0 5 3 vertxInternal Lio/vertx/core/impl/VertxInternal;
MethodParameters:
Name Flags
ignite
nodeSelector
vertxInternal
public void get(java.lang.String, io.vertx.core.Promise<java.util.List<io.vertx.core.spi.cluster.RegistrationInfo>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.map:Lorg/apache/ignite/IgniteCache;
new org.apache.ignite.cache.query.ScanQuery
dup
aload 1
invokedynamic apply(Ljava/lang/String;)Lorg/apache/ignite/lang/IgniteBiPredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/impl/SubsMapHelper.lambda$1(Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z (6)
(Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z
1
invokespecial org.apache.ignite.cache.query.ScanQuery.<init>:(Lorg/apache/ignite/lang/IgniteBiPredicate;)V
invokeinterface org.apache.ignite.IgniteCache.query:(Lorg/apache/ignite/cache/query/Query;)Lorg/apache/ignite/cache/query/QueryCursor;
1: invokeinterface org.apache.ignite.cache.query.QueryCursor.getAll:()Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
2: 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;
javax/cache/Cache$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljavax/cache/Cache$Entry;)Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
3: 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;
io/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo.registrationInfo()Lio/vertx/core/spi/cluster/RegistrationInfo; (5)
(Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;)Lio/vertx/core/spi/cluster/RegistrationInfo;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
4: 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
5: astore 3
start local 3 6: aload 2
aload 3
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 7: goto 10
StackMap locals:
StackMap stack: java.lang.RuntimeException
8: astore 3
start local 3 9: aload 2
new io.vertx.core.VertxException
dup
aload 3
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
end local 3 10: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 11 1 address Ljava/lang/String;
0 11 2 promise Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;
6 7 3 infos Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;
9 10 3 e Ljava/lang/RuntimeException;
Exception table:
from to target type
0 7 8 Class java.lang.IllegalStateException
0 7 8 Class javax.cache.CacheException
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;)V
MethodParameters:
Name Flags
address
promise
public io.vertx.core.Future<java.lang.Void> put(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo);
descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.map:Lorg/apache/ignite/IgniteCache;
new io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo
dup
aload 1
aload 2
invokespecial io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo.<init>:(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)V
getstatic java.lang.Boolean.TRUE:Ljava/lang/Boolean;
invokeinterface org.apache.ignite.IgniteCache.put:(Ljava/lang/Object;Ljava/lang/Object;)V
1: goto 4
StackMap locals:
StackMap stack: java.lang.RuntimeException
2: astore 3
start local 3 3: new io.vertx.core.VertxException
dup
aload 3
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/Throwable;)V
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
areturn
end local 3 4: StackMap locals:
StackMap stack:
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 5 1 address Ljava/lang/String;
0 5 2 registrationInfo Lio/vertx/core/spi/cluster/RegistrationInfo;
3 4 3 e Ljava/lang/RuntimeException;
Exception table:
from to target type
0 1 2 Class java.lang.IllegalStateException
0 1 2 Class javax.cache.CacheException
Signature: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
address
registrationInfo
public void remove(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.map:Lorg/apache/ignite/IgniteCache;
new io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo
dup
aload 1
aload 2
invokespecial io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo.<init>:(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)V
invokeinterface org.apache.ignite.IgniteCache.remove:(Ljava/lang/Object;)Z
pop
1: aload 3
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 5
StackMap locals:
StackMap stack: java.lang.RuntimeException
3: astore 4
start local 4 4: aload 3
new io.vertx.core.VertxException
dup
aload 4
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
end local 4 5: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 6 1 address Ljava/lang/String;
0 6 2 registrationInfo Lio/vertx/core/spi/cluster/RegistrationInfo;
0 6 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
4 5 4 e Ljava/lang/RuntimeException;
Exception table:
from to target type
0 2 3 Class java.lang.IllegalStateException
0 2 3 Class javax.cache.CacheException
Signature: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
address
registrationInfo
promise
public void removeAllForNode(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.map:Lorg/apache/ignite/IgniteCache;
new org.apache.ignite.cache.query.ScanQuery
dup
aload 1
invokedynamic apply(Ljava/lang/String;)Lorg/apache/ignite/lang/IgniteBiPredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/impl/SubsMapHelper.lambda$4(Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z (6)
(Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z
1
invokespecial org.apache.ignite.cache.query.ScanQuery.<init>:(Lorg/apache/ignite/lang/IgniteBiPredicate;)V
invokeinterface org.apache.ignite.IgniteCache.query:(Lorg/apache/ignite/cache/query/Query;)Lorg/apache/ignite/cache/query/QueryCursor;
1: invokeinterface org.apache.ignite.cache.query.QueryCursor.getAll:()Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
2: 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;
javax/cache/Cache$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljavax/cache/Cache$Entry;)Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
3: invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Set
4: astore 2
start local 2 5: aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.map:Lorg/apache/ignite/IgniteCache;
aload 2
invokeinterface org.apache.ignite.IgniteCache.removeAll:(Ljava/util/Set;)V
6: goto 8
StackMap locals: io.vertx.spi.cluster.ignite.impl.SubsMapHelper java.lang.String java.util.Set
StackMap stack: java.lang.RuntimeException
7: pop
8: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 9 1 nodeId Ljava/lang/String;
5 9 2 toRemove Ljava/util/Set<Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;>;
Exception table:
from to target type
5 6 7 Class java.lang.IllegalStateException
5 6 7 Class javax.cache.CacheException
MethodParameters:
Name Flags
nodeId
boolean listen(org.apache.ignite.events.Event, io.vertx.core.spi.cluster.NodeSelector, io.vertx.core.impl.VertxInternal);
descriptor: (Lorg/apache/ignite/events/Event;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;)Z
flags: (0x0000)
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
instanceof org.apache.ignite.events.CacheEvent
ifne 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.ignite.events.CacheEvent
astore 4
start local 4 3: aload 4
invokevirtual org.apache.ignite.events.CacheEvent.cacheName:()Ljava/lang/String;
aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.map:Lorg/apache/ignite/IgniteCache;
invokeinterface org.apache.ignite.IgniteCache.getName:()Ljava/lang/String;
invokestatic java.util.Objects.equals:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 5
4: iconst_1
ireturn
5: StackMap locals: org.apache.ignite.events.CacheEvent
StackMap stack:
aload 3
aload 0
aload 4
aload 2
invokedynamic handle(Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;Lorg/apache/ignite/events/CacheEvent;Lio/vertx/core/spi/cluster/NodeSelector;)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/spi/cluster/ignite/impl/SubsMapHelper.lambda$6(Lorg/apache/ignite/events/CacheEvent;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
6: iconst_1
ireturn
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/spi/cluster/ignite/impl/SubsMapHelper;
0 7 1 event Lorg/apache/ignite/events/Event;
0 7 2 nodeSelector Lio/vertx/core/spi/cluster/NodeSelector;
0 7 3 vertxInternal Lio/vertx/core/impl/VertxInternal;
3 7 4 cacheEvent Lorg/apache/ignite/events/CacheEvent;
MethodParameters:
Name Flags
event
nodeSelector final
vertxInternal final
public void leave(org.apache.ignite.Ignite);
descriptor: (Lorg/apache/ignite/Ignite;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
ifnull 2
1: aload 1
invokeinterface org.apache.ignite.Ignite.events:()Lorg/apache/ignite/IgniteEvents;
aload 0
getfield io.vertx.spi.cluster.ignite.impl.SubsMapHelper.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
getstatic io.vertx.spi.cluster.ignite.impl.SubsMapHelper.CACHE_EVENTS:[I
invokeinterface org.apache.ignite.IgniteEvents.stopLocalListen:(Lorg/apache/ignite/lang/IgnitePredicate;[I)Z
pop
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 3 1 ignite Lorg/apache/ignite/Ignite;
MethodParameters:
Name Flags
ignite
private boolean lambda$0(io.vertx.core.spi.cluster.NodeSelector, io.vertx.core.impl.VertxInternal, org.apache.ignite.events.Event);
descriptor: (Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;Lorg/apache/ignite/events/Event;)Z
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 3 0: aload 0
aload 3
aload 1
aload 2
invokevirtual io.vertx.spi.cluster.ignite.impl.SubsMapHelper.listen:(Lorg/apache/ignite/events/Event;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;)Z
ireturn
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 1 3 event Lorg/apache/ignite/events/Event;
private static boolean lambda$1(java.lang.String, io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo, java.lang.Boolean);
descriptor: (Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 1
invokevirtual io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo.address:()Ljava/lang/String;
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 k Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;
0 1 2 v Ljava/lang/Boolean;
private static boolean lambda$4(java.lang.String, io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo, java.lang.Boolean);
descriptor: (Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 1
invokevirtual io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo.registrationInfo:()Lio/vertx/core/spi/cluster/RegistrationInfo;
invokevirtual io.vertx.core.spi.cluster.RegistrationInfo.nodeId:()Ljava/lang/String;
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 k Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;
0 1 2 v Ljava/lang/Boolean;
private void lambda$6(org.apache.ignite.events.CacheEvent, io.vertx.core.spi.cluster.NodeSelector, io.vertx.core.Promise);
descriptor: (Lorg/apache/ignite/events/CacheEvent;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 3 0: aload 1
invokevirtual org.apache.ignite.events.CacheEvent.key:()Ljava/lang/Object;
checkcast io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo
invokevirtual io.vertx.spi.cluster.ignite.impl.IgniteRegistrationInfo.address:()Ljava/lang/String;
astore 4
start local 4 1: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 2
aload 4
invokedynamic handle(Lio/vertx/core/spi/cluster/NodeSelector;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/spi/cluster/ignite/impl/SubsMapHelper.lambda$7(Lio/vertx/core/spi/cluster/NodeSelector;Ljava/lang/String;Ljava/util/List;)V (6)
(Ljava/util/List;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
2: aload 0
aload 4
aload 3
invokevirtual io.vertx.spi.cluster.ignite.impl.SubsMapHelper.get:(Ljava/lang/String;Lio/vertx/core/Promise;)V
end local 4 3: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;
0 4 3 promise Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;
1 3 4 address Ljava/lang/String;
private static void lambda$7(io.vertx.core.spi.cluster.NodeSelector, java.lang.String, java.util.List);
descriptor: (Lio/vertx/core/spi/cluster/NodeSelector;Ljava/lang/String;Ljava/util/List;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=3
start local 2 0: aload 0
new io.vertx.core.spi.cluster.RegistrationUpdateEvent
dup
aload 1
aload 2
invokespecial io.vertx.core.spi.cluster.RegistrationUpdateEvent.<init>:(Ljava/lang/String;Ljava/util/List;)V
invokeinterface io.vertx.core.spi.cluster.NodeSelector.registrationsUpdated:(Lio/vertx/core/spi/cluster/RegistrationUpdateEvent;)V
1: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 2 2 registrationInfos Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;
private static java.lang.Object $deserializeLambda$(java.lang.invoke.SerializedLambda);
descriptor: (Ljava/lang/invoke/SerializedLambda;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=8, locals=3, args_size=1
0: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodName:()Ljava/lang/String;
astore 1
iconst_m1
istore 2
aload 1
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 3
-1647345005: 1
-1647345004: 2
-1647345001: 3
default: 4
}
StackMap locals: java.lang.String int
StackMap stack:
1: aload 1
ldc "lambda$0"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
iconst_0
istore 2
goto 4
StackMap locals:
StackMap stack:
2: aload 1
ldc "lambda$1"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
iconst_1
istore 2
goto 4
StackMap locals:
StackMap stack:
3: aload 1
ldc "lambda$4"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
iconst_2
istore 2
StackMap locals:
StackMap stack:
4: iload 2
lookupswitch { // 3
0: 5
1: 6
2: 7
default: 8
}
StackMap locals:
StackMap stack:
5: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 7
if_icmpne 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/lang/IgnitePredicate"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "apply"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/impl/SubsMapHelper"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;Lorg/apache/ignite/events/Event;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast io.vertx.spi.cluster.ignite.impl.SubsMapHelper
aload 0
iconst_1
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast io.vertx.core.spi.cluster.NodeSelector
aload 0
iconst_2
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast io.vertx.core.impl.VertxInternal
invokedynamic apply(Lio/vertx/spi/cluster/ignite/impl/SubsMapHelper;Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;)Lorg/apache/ignite/lang/IgnitePredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/impl/SubsMapHelper.lambda$0(Lio/vertx/core/spi/cluster/NodeSelector;Lio/vertx/core/impl/VertxInternal;Lorg/apache/ignite/events/Event;)Z (7)
(Lorg/apache/ignite/events/Event;)Z
1
areturn
StackMap locals:
StackMap stack:
6: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/lang/IgniteBiPredicate"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "apply"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;Ljava/lang/Object;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/impl/SubsMapHelper"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast java.lang.String
invokedynamic apply(Ljava/lang/String;)Lorg/apache/ignite/lang/IgniteBiPredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/impl/SubsMapHelper.lambda$1(Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z (6)
(Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z
1
areturn
StackMap locals:
StackMap stack:
7: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/lang/IgniteBiPredicate"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "apply"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;Ljava/lang/Object;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/impl/SubsMapHelper"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast java.lang.String
invokedynamic apply(Ljava/lang/String;)Lorg/apache/ignite/lang/IgniteBiPredicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Z
io/vertx/spi/cluster/ignite/impl/SubsMapHelper.lambda$4(Ljava/lang/String;Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z (6)
(Lio/vertx/spi/cluster/ignite/impl/IgniteRegistrationInfo;Ljava/lang/Boolean;)Z
1
areturn
StackMap locals:
StackMap stack:
8: new java.lang.IllegalArgumentException
dup
ldc "Invalid lambda deserialization"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "SubsMapHelper.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = javax.cache.Cache$Entry of javax.cache.Cache