public class io.vertx.spi.cluster.hazelcast.HazelcastClusterManager implements io.vertx.core.spi.cluster.ClusterManager, com.hazelcast.cluster.MembershipListener, com.hazelcast.core.LifecycleListener
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager
super_class: java.lang.Object
{
private static final io.vertx.core.impl.logging.Logger log;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.String LOCK_SEMAPHORE_PREFIX;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "__vertx."
private io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.spi.cluster.NodeSelector nodeSelector;
descriptor: Lio/vertx/core/spi/cluster/NodeSelector;
flags: (0x0002) ACC_PRIVATE
private com.hazelcast.core.HazelcastInstance hazelcast;
descriptor: Lcom/hazelcast/core/HazelcastInstance;
flags: (0x0002) ACC_PRIVATE
private java.util.UUID nodeId;
descriptor: Ljava/util/UUID;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.spi.cluster.NodeInfo nodeInfo;
descriptor: Lio/vertx/core/spi/cluster/NodeInfo;
flags: (0x0002) ACC_PRIVATE
private io.vertx.spi.cluster.hazelcast.impl.SubsMapHelper subsMapHelper;
descriptor: Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
flags: (0x0002) ACC_PRIVATE
private com.hazelcast.map.IMap<java.lang.String, io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo> nodeInfoMap;
descriptor: Lcom/hazelcast/map/IMap;
flags: (0x0002) ACC_PRIVATE
Signature: Lcom/hazelcast/map/IMap<Ljava/lang/String;Lio/vertx/spi/cluster/hazelcast/impl/HazelcastNodeInfo;>;
private java.util.UUID membershipListenerId;
descriptor: Ljava/util/UUID;
flags: (0x0002) ACC_PRIVATE
private java.util.UUID lifecycleListenerId;
descriptor: Ljava/util/UUID;
flags: (0x0002) ACC_PRIVATE
private boolean customHazelcastCluster;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private java.util.Set<java.lang.String> nodeIds;
descriptor: Ljava/util/Set;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Set<Ljava/lang/String;>;
private io.vertx.core.spi.cluster.NodeListener nodeListener;
descriptor: Lio/vertx/core/spi/cluster/NodeListener;
flags: (0x0002) ACC_PRIVATE
private volatile boolean active;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private com.hazelcast.config.Config conf;
descriptor: Lcom/hazelcast/config/Config;
flags: (0x0002) ACC_PRIVATE
private java.util.concurrent.ExecutorService lockReleaseExec;
descriptor: Ljava/util/concurrent/ExecutorService;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/impl/logging/Logger;
1: 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.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
public void <init>(com.hazelcast.config.Config);
descriptor: (Lcom/hazelcast/config/Config;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
2: aload 1
ldc "The Hazelcast config cannot be null."
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 5 1 conf Lcom/hazelcast/config/Config;
MethodParameters:
Name Flags
conf
public void <init>(com.hazelcast.core.HazelcastInstance);
descriptor: (Lcom/hazelcast/core/HazelcastInstance;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
2: aload 1
ldc "The Hazelcast instance cannot be null."
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
3: aload 0
aload 1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
4: aload 0
iconst_1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 6 1 instance Lcom/hazelcast/core/HazelcastInstance;
MethodParameters:
Name Flags
instance
public void init(io.vertx.core.Vertx, io.vertx.core.spi.cluster.NodeSelector);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/spi/cluster/NodeSelector;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
1: aload 0
aload 2
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 3 1 vertx Lio/vertx/core/Vertx;
0 3 2 nodeSelector Lio/vertx/core/spi/cluster/NodeSelector;
MethodParameters:
Name Flags
vertx
nodeSelector
public void join(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)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.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
invokedynamic handle(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;)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/hazelcast/HazelcastClusterManager.lambda$0(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 1
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 4 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
promise
public java.lang.String getNodeId();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeId:Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
public java.util.List<java.lang.String> getNodes();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 1
start local 1 1: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCluster:()Lcom/hazelcast/cluster/Cluster;
invokeinterface com.hazelcast.cluster.Cluster.getMembers:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 3
goto 4
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.util.List top java.util.Iterator
StackMap stack:
2: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.hazelcast.cluster.Member
astore 2
start local 2 3: aload 1
aload 2
invokeinterface com.hazelcast.cluster.Member.getUuid:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 2 4: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
1 6 1 list Ljava/util/List<Ljava/lang/String;>;
3 4 2 member Lcom/hazelcast/cluster/Member;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public void nodeListener(io.vertx.core.spi.cluster.NodeListener);
descriptor: (Lio/vertx/core/spi/cluster/NodeListener;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 2 1 listener Lio/vertx/core/spi/cluster/NodeListener;
MethodParameters:
Name Flags
listener
public void setNodeInfo(io.vertx.core.spi.cluster.NodeInfo, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/spi/cluster/NodeInfo;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
dup
astore 3
monitorenter
1: aload 0
aload 1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeInfo:Lio/vertx/core/spi/cluster/NodeInfo;
2: aload 3
monitorexit
3: goto 6
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager io.vertx.core.spi.cluster.NodeInfo io.vertx.core.Promise io.vertx.spi.cluster.hazelcast.HazelcastClusterManager
StackMap stack: java.lang.Throwable
4: aload 3
monitorexit
5: athrow
6: StackMap locals:
StackMap stack:
new io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo
dup
aload 1
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo.<init>:(Lio/vertx/core/spi/cluster/NodeInfo;)V
astore 3
start local 3 7: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 3
invokedynamic handle(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;Lio/vertx/spi/cluster/hazelcast/impl/HazelcastNodeInfo;)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/hazelcast/HazelcastClusterManager.lambda$2(Lio/vertx/spi/cluster/hazelcast/impl/HazelcastNodeInfo;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
8: iconst_0
aload 2
9: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
10: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 11 1 nodeInfo Lio/vertx/core/spi/cluster/NodeInfo;
0 11 2 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
7 11 3 value Lio/vertx/spi/cluster/hazelcast/impl/HazelcastNodeInfo;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Lio/vertx/core/spi/cluster/NodeInfo;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
nodeInfo
promise
public synchronized io.vertx.core.spi.cluster.NodeInfo getNodeInfo();
descriptor: ()Lio/vertx/core/spi/cluster/NodeInfo;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeInfo:Lio/vertx/core/spi/cluster/NodeInfo;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
public void getNodeInfo(java.lang.String, io.vertx.core.Promise<io.vertx.core.spi.cluster.NodeInfo>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;Ljava/lang/String;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/spi/cluster/hazelcast/HazelcastClusterManager.lambda$3(Ljava/lang/String;Lio/vertx/core/Promise;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 2
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 4 1 nodeId Ljava/lang/String;
0 4 2 promise Lio/vertx/core/Promise<Lio/vertx/core/spi/cluster/NodeInfo;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Lio/vertx/core/spi/cluster/NodeInfo;>;)V
MethodParameters:
Name Flags
nodeId
promise
public <K, V> void getAsyncMap(java.lang.String, io.vertx.core.Promise<io.vertx.core.shareddata.AsyncMap<K, V>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
new io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMap
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
aload 1
invokeinterface com.hazelcast.core.HazelcastInstance.getMap:(Ljava/lang/String;)Lcom/hazelcast/map/IMap;
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMap.<init>:(Lio/vertx/core/impl/VertxInternal;Lcom/hazelcast/map/IMap;)V
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 2 1 name Ljava/lang/String;
0 2 2 promise Lio/vertx/core/Promise<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;Lio/vertx/core/Promise<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;)V
MethodParameters:
Name Flags
name
promise
public <K, V> java.util.Map<K, V> getSyncMap(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
aload 1
invokeinterface com.hazelcast.core.HazelcastInstance.getMap:(Ljava/lang/String;)Lcom/hazelcast/map/IMap;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 1 1 name Ljava/lang/String;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;)Ljava/util/Map<TK;TV;>;
MethodParameters:
Name Flags
name
public void getLockWithTimeout(java.lang.String, long, io.vertx.core.Promise<io.vertx.core.shareddata.Lock>);
descriptor: (Ljava/lang/String;JLio/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 4 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
lload 2
invokedynamic handle(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;Ljava/lang/String;J)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/hazelcast/HazelcastClusterManager.lambda$4(Ljava/lang/String;JLio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 4
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 4 1 name Ljava/lang/String;
0 4 2 timeout J
0 4 4 promise Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;
Signature: (Ljava/lang/String;JLio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;)V
MethodParameters:
Name Flags
name
timeout
promise
public void getCounter(java.lang.String, io.vertx.core.Promise<io.vertx.core.shareddata.Counter>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
new io.vertx.spi.cluster.hazelcast.impl.HazelcastCounter
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCPSubsystem:()Lcom/hazelcast/cp/CPSubsystem;
aload 1
invokeinterface com.hazelcast.cp.CPSubsystem.getAtomicLong:(Ljava/lang/String;)Lcom/hazelcast/cp/IAtomicLong;
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastCounter.<init>:(Lio/vertx/core/impl/VertxInternal;Lcom/hazelcast/cp/IAtomicLong;)V
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 2 1 name Ljava/lang/String;
0 2 2 promise Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Counter;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Counter;>;)V
MethodParameters:
Name Flags
name
promise
public void leave(io.vertx.core.Promise<java.lang.Void>);
descriptor: (Lio/vertx/core/Promise;)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.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
invokedynamic handle(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;)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/hazelcast/HazelcastClusterManager.lambda$5(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 1
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 4 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
promise
public synchronized void memberAdded(com.hazelcast.cluster.MembershipEvent);
descriptor: (Lcom/hazelcast/cluster/MembershipEvent;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual com.hazelcast.cluster.MembershipEvent.getMember:()Lcom/hazelcast/cluster/Member;
astore 2
start local 2 3: aload 2
invokeinterface com.hazelcast.cluster.Member.getUuid:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
astore 3
start local 3 4: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
ifnull 10
5: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
aload 3
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
6: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
aload 3
invokeinterface io.vertx.core.spi.cluster.NodeListener.nodeAdded:(Ljava/lang/String;)V
7: goto 10
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager com.hazelcast.cluster.MembershipEvent com.hazelcast.cluster.Member java.lang.String
StackMap stack: java.lang.Throwable
8: astore 4
start local 4 9: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "Failed to handle memberAdded"
aload 4
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 4 10: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 11 1 membershipEvent Lcom/hazelcast/cluster/MembershipEvent;
3 11 2 member Lcom/hazelcast/cluster/Member;
4 11 3 nid Ljava/lang/String;
9 10 4 t Ljava/lang/Throwable;
Exception table:
from to target type
4 7 8 Class java.lang.Throwable
MethodParameters:
Name Flags
membershipEvent
public synchronized void memberRemoved(com.hazelcast.cluster.MembershipEvent);
descriptor: (Lcom/hazelcast/cluster/MembershipEvent;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual com.hazelcast.cluster.MembershipEvent.getMember:()Lcom/hazelcast/cluster/Member;
astore 2
start local 2 3: aload 2
invokeinterface com.hazelcast.cluster.Member.getUuid:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
astore 3
start local 3 4: aload 0
aload 3
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.membersRemoved:(Ljava/util/Set;)V
5: goto 8
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager com.hazelcast.cluster.MembershipEvent com.hazelcast.cluster.Member java.lang.String
StackMap stack: java.lang.Throwable
6: astore 4
start local 4 7: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "Failed to handle memberRemoved"
aload 4
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 4 8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 9 1 membershipEvent Lcom/hazelcast/cluster/MembershipEvent;
3 9 2 member Lcom/hazelcast/cluster/Member;
4 9 3 nid Ljava/lang/String;
7 8 4 t Ljava/lang/Throwable;
Exception table:
from to target type
4 5 6 Class java.lang.Throwable
MethodParameters:
Name Flags
membershipEvent
private synchronized void membersRemoved(java.util.Set<java.lang.String>);
descriptor: (Ljava/util/Set;)V
flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.cleanSubs:(Ljava/util/Set;)V
1: aload 0
aload 1
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.cleanNodeInfos:(Ljava/util/Set;)V
2: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeInfoMap:Lcom/hazelcast/map/IMap;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeId:Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
new io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo
dup
aload 0
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.getNodeInfo:()Lio/vertx/core/spi/cluster/NodeInfo;
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo.<init>:(Lio/vertx/core/spi/cluster/NodeInfo;)V
invokeinterface com.hazelcast.map.IMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
invokeinterface io.vertx.core.spi.cluster.NodeSelector.registrationsLost:()V
4: aload 0
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.republishOwnSubs:()V
5: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
ifnull 8
6: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.removeAll:(Ljava/util/Collection;)Z
pop
7: aload 1
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lio/vertx/core/spi/cluster/NodeListener;)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/core/spi/cluster/NodeListener.nodeLeft(Ljava/lang/String;)V (9 itf)
(Ljava/lang/String;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 9 1 ids Ljava/util/Set<Ljava/lang/String;>;
Signature: (Ljava/util/Set<Ljava/lang/String;>;)V
MethodParameters:
Name Flags
ids
private void cleanSubs(java.util.Set<java.lang.String>);
descriptor: (Ljava/util/Set;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.subsMapHelper:Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
aload 1
invokevirtual io.vertx.spi.cluster.hazelcast.impl.SubsMapHelper.removeAllForNodes:(Ljava/util/Set;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 2 1 ids Ljava/util/Set<Ljava/lang/String;>;
Signature: (Ljava/util/Set<Ljava/lang/String;>;)V
MethodParameters:
Name Flags
ids
private void cleanNodeInfos(java.util.Set<java.lang.String>);
descriptor: (Ljava/util/Set;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeInfoMap:Lcom/hazelcast/map/IMap;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lcom/hazelcast/map/IMap;)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
com/hazelcast/map/IMap.remove(Ljava/lang/Object;)Ljava/lang/Object; (9 itf)
(Ljava/lang/String;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 2 1 ids Ljava/util/Set<Ljava/lang/String;>;
Signature: (Ljava/util/Set<Ljava/lang/String;>;)V
MethodParameters:
Name Flags
ids
private void republishOwnSubs();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
invokedynamic handle(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;)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/hazelcast/HazelcastClusterManager.lambda$8(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;Z)Lio/vertx/core/Future;
pop
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
public synchronized void stateChanged(com.hazelcast.core.LifecycleEvent);
descriptor: (Lcom/hazelcast/core/LifecycleEvent;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=3, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual com.hazelcast.core.LifecycleEvent.getState:()Lcom/hazelcast/core/LifecycleEvent$LifecycleState;
getstatic com.hazelcast.core.LifecycleEvent$LifecycleState.MERGED:Lcom/hazelcast/core/LifecycleEvent$LifecycleState;
if_acmpne 14
3: aload 0
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.getNodes:()Ljava/util/List;
astore 2
start local 2 4: new java.util.HashSet
dup
aload 2
invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
astore 3
start local 3 5: aload 3
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
invokeinterface java.util.Set.removeAll:(Ljava/util/Collection;)Z
pop
6: new java.util.HashSet
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
astore 4
start local 4 7: aload 4
aload 2
invokeinterface java.util.Set.removeAll:(Ljava/util/Collection;)Z
pop
8: aload 3
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 11
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager com.hazelcast.core.LifecycleEvent java.util.List java.util.Set java.util.Set top java.util.Iterator
StackMap stack:
9: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 5
start local 5 10: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
aload 5
invokeinterface io.vertx.core.spi.cluster.NodeListener.nodeAdded:(Ljava/lang/String;)V
end local 5 11: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: aload 0
aload 4
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.membersRemoved:(Ljava/util/Set;)V
13: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
aload 2
invokeinterface java.util.Set.retainAll:(Ljava/util/Collection;)Z
pop
end local 4 end local 3 end local 2 14: StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager com.hazelcast.core.LifecycleEvent
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 15 1 lifecycleEvent Lcom/hazelcast/core/LifecycleEvent;
4 14 2 currentNodes Ljava/util/List<Ljava/lang/String;>;
5 14 3 newNodes Ljava/util/Set<Ljava/lang/String;>;
7 14 4 removedMembers Ljava/util/Set<Ljava/lang/String;>;
10 11 5 nodeId Ljava/lang/String;
MethodParameters:
Name Flags
lifecycleEvent
public boolean isActive();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
public void addRegistration(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.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokestatic io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.get:(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
astore 4
start local 4 1: aload 4
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.subsMapHelper:Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;)Ljava/util/function/BiConsumer;
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;)V
io/vertx/spi/cluster/hazelcast/impl/SubsMapHelper.put(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)V (5)
(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)V
aload 1
aload 2
aload 3
invokevirtual io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.execute:(Ljava/util/function/BiConsumer;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
2: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 3 1 address Ljava/lang/String;
0 3 2 registrationInfo Lio/vertx/core/spi/cluster/RegistrationInfo;
0 3 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
1 3 4 serializer Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
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 removeRegistration(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.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
invokestatic io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.get:(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
astore 4
start local 4 1: aload 4
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.subsMapHelper:Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;)Ljava/util/function/BiConsumer;
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;)V
io/vertx/spi/cluster/hazelcast/impl/SubsMapHelper.remove(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)V (5)
(Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)V
aload 1
aload 2
aload 3
invokevirtual io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.execute:(Ljava/util/function/BiConsumer;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
2: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 3 1 address Ljava/lang/String;
0 3 2 registrationInfo Lio/vertx/core/spi/cluster/RegistrationInfo;
0 3 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
1 3 4 serializer Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
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 getRegistrations(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=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
aload 1
invokedynamic handle(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;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/hazelcast/HazelcastClusterManager.lambda$11(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 2
2: invokeinterface io.vertx.core.impl.VertxInternal.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 4 1 address Ljava/lang/String;
0 4 2 promise Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;)V
MethodParameters:
Name Flags
address
promise
public java.lang.String clusterHost();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 3
ldc "hazelcast.local.localAddress"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
dup
astore 1
start local 1 1: ifnull 3
2: aload 1
areturn
end local 1 3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 5
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
invokevirtual com.hazelcast.config.Config.getNetworkConfig:()Lcom/hazelcast/config/NetworkConfig;
invokevirtual com.hazelcast.config.NetworkConfig.getPublicAddress:()Ljava/lang/String;
ifnonnull 5
4: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCluster:()Lcom/hazelcast/cluster/Cluster;
invokeinterface com.hazelcast.cluster.Cluster.getLocalMember:()Lcom/hazelcast/cluster/Member;
invokeinterface com.hazelcast.cluster.Member.getAddress:()Lcom/hazelcast/cluster/Address;
invokevirtual com.hazelcast.cluster.Address.getHost:()Ljava/lang/String;
areturn
5: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
1 3 1 host Ljava/lang/String;
public java.lang.String clusterPublicHost();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 3
ldc "hazelcast.local.publicAddress"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
dup
astore 1
start local 1 1: ifnull 3
2: aload 1
areturn
end local 1 3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 6
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
invokevirtual com.hazelcast.config.Config.getNetworkConfig:()Lcom/hazelcast/config/NetworkConfig;
invokevirtual com.hazelcast.config.NetworkConfig.getPublicAddress:()Ljava/lang/String;
dup
astore 1
start local 1 4: ifnull 6
5: aload 1
areturn
end local 1 6: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
1 3 1 host Ljava/lang/String;
4 6 1 host Ljava/lang/String;
public com.hazelcast.config.Config getConfig();
descriptor: ()Lcom/hazelcast/config/Config;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
public void setConfig(com.hazelcast.config.Config);
descriptor: (Lcom/hazelcast/config/Config;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 2 1 config Lcom/hazelcast/config/Config;
MethodParameters:
Name Flags
config
public com.hazelcast.config.Config loadConfig();
descriptor: ()Lcom/hazelcast/config/Config;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: invokestatic io.vertx.spi.cluster.hazelcast.ConfigUtil.loadConfig:()Lcom/hazelcast/config/Config;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
public com.hazelcast.core.HazelcastInstance getHazelcastInstance();
descriptor: ()Lcom/hazelcast/core/HazelcastInstance;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
private void lambda$0(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
ifne 18
1: aload 0
iconst_1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
2: aload 0
invokedynamic newThread()Ljava/util/concurrent/ThreadFactory;
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/Runnable;)Ljava/lang/Thread;
io/vertx/spi/cluster/hazelcast/HazelcastClusterManager.lambda$1(Ljava/lang/Runnable;)Ljava/lang/Thread; (6)
(Ljava/lang/Runnable;)Ljava/lang/Thread;
invokestatic java.util.concurrent.Executors.newCachedThreadPool:(Ljava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ExecutorService;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.lockReleaseExec:Ljava/util/concurrent/ExecutorService;
3: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 11
4: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
ifnonnull 9
5: aload 0
aload 0
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.loadConfig:()Lcom/hazelcast/config/Config;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
6: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
ifnonnull 9
7: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "Cannot find cluster configuration on 'vertx.hazelcast.config' system property, on the classpath, or specified programmatically. Using default hazelcast configuration"
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
8: aload 0
new com.hazelcast.config.Config
dup
invokespecial com.hazelcast.config.Config.<init>:()V
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
9: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
ldc "hazelcast.shutdownhook.enabled"
ldc "false"
invokevirtual com.hazelcast.config.Config.setProperty:(Ljava/lang/String;Ljava/lang/String;)Lcom/hazelcast/config/Config;
pop
10: aload 0
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
invokestatic com.hazelcast.core.Hazelcast.newHazelcastInstance:(Lcom/hazelcast/config/Config;)Lcom/hazelcast/core/HazelcastInstance;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
11: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCluster:()Lcom/hazelcast/cluster/Cluster;
invokeinterface com.hazelcast.cluster.Cluster.getLocalMember:()Lcom/hazelcast/cluster/Member;
astore 2
start local 2 12: aload 0
aload 2
invokeinterface com.hazelcast.cluster.Member.getUuid:()Ljava/util/UUID;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeId:Ljava/util/UUID;
13: aload 0
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCluster:()Lcom/hazelcast/cluster/Cluster;
aload 0
invokeinterface com.hazelcast.cluster.Cluster.addMembershipListener:(Lcom/hazelcast/cluster/MembershipListener;)Ljava/util/UUID;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.membershipListenerId:Ljava/util/UUID;
14: aload 0
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getLifecycleService:()Lcom/hazelcast/core/LifecycleService;
aload 0
invokeinterface com.hazelcast.core.LifecycleService.addLifecycleListener:(Lcom/hazelcast/core/LifecycleListener;)Ljava/util/UUID;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.lifecycleListenerId:Ljava/util/UUID;
15: aload 0
new io.vertx.spi.cluster.hazelcast.impl.SubsMapHelper
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
invokespecial io.vertx.spi.cluster.hazelcast.impl.SubsMapHelper.<init>:(Lio/vertx/core/impl/VertxInternal;Lcom/hazelcast/core/HazelcastInstance;Lio/vertx/core/spi/cluster/NodeSelector;)V
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.subsMapHelper:Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
16: aload 0
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
ldc "__vertx.nodeInfo"
invokeinterface com.hazelcast.core.HazelcastInstance.getMap:(Ljava/lang/String;)Lcom/hazelcast/map/IMap;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeInfoMap:Lcom/hazelcast/map/IMap;
17: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
end local 2 18: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 19 1 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
12 18 2 localMember Lcom/hazelcast/cluster/Member;
private void lambda$2(io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo, io.vertx.core.Promise);
descriptor: (Lio/vertx/spi/cluster/hazelcast/impl/HazelcastNodeInfo;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeInfoMap:Lcom/hazelcast/map/IMap;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeId:Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
aload 1
invokeinterface com.hazelcast.map.IMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 2
invokeinterface io.vertx.core.Promise.complete:()V
2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 3 2 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
private void lambda$3(java.lang.String, io.vertx.core.Promise, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=5, args_size=4
start local 0 start local 3 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeInfoMap:Lcom/hazelcast/map/IMap;
aload 1
invokeinterface com.hazelcast.map.IMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo
astore 4
start local 4 1: aload 4
ifnull 4
2: aload 3
aload 4
invokevirtual io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo.unwrap:()Lio/vertx/core/spi/cluster/NodeInfo;
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
3: goto 5
4: StackMap locals: io.vertx.spi.cluster.hazelcast.impl.HazelcastNodeInfo
StackMap stack:
aload 2
ldc "Not a member of the cluster"
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
end local 4 5: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 6 3 prom Lio/vertx/core/Promise<Lio/vertx/core/spi/cluster/NodeInfo;>;
1 5 4 value Lio/vertx/spi/cluster/hazelcast/impl/HazelcastNodeInfo;
private void lambda$4(java.lang.String, long, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;JLio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=7, locals=11, args_size=4
start local 0 start local 4 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCPSubsystem:()Lcom/hazelcast/cp/CPSubsystem;
new java.lang.StringBuilder
dup
ldc "__vertx."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface com.hazelcast.cp.CPSubsystem.getSemaphore:(Ljava/lang/String;)Lcom/hazelcast/cp/ISemaphore;
astore 5
start local 5 1: iconst_0
istore 6
start local 6 2: lload 2
lstore 7
start local 7 3: StackMap locals: com.hazelcast.cp.ISemaphore int long
StackMap stack:
invokestatic java.lang.System.nanoTime:()J
lstore 9
start local 9 4: aload 5
lload 7
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface com.hazelcast.cp.ISemaphore.tryAcquire:(JLjava/util/concurrent/TimeUnit;)Z
istore 6
5: goto 7
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.lang.String long io.vertx.core.Promise com.hazelcast.cp.ISemaphore int long long
StackMap stack: java.lang.InterruptedException
6: pop
7: StackMap locals:
StackMap stack:
lload 7
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic java.lang.System.nanoTime:()J
lload 9
lsub
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual java.util.concurrent.TimeUnit.convert:(JLjava/util/concurrent/TimeUnit;)J
lsub
lstore 7
end local 9 8: iload 6
ifne 10
lload 7
lconst_0
9: lcmp
ifgt 3
10: StackMap locals:
StackMap stack:
iload 6
ifeq 13
11: aload 4
new io.vertx.spi.cluster.hazelcast.impl.HazelcastLock
dup
aload 5
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.lockReleaseExec:Ljava/util/concurrent/ExecutorService;
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastLock.<init>:(Lcom/hazelcast/cp/ISemaphore;Ljava/util/concurrent/Executor;)V
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
12: goto 14
13: StackMap locals:
StackMap stack:
new io.vertx.core.VertxException
dup
new java.lang.StringBuilder
dup
ldc "Timed out waiting to get lock "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;)V
athrow
end local 7 end local 6 end local 5 14: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 15 4 prom Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;
1 14 5 iSemaphore Lcom/hazelcast/cp/ISemaphore;
2 14 6 locked Z
3 14 7 remaining J
4 8 9 start J
Exception table:
from to target type
4 5 6 Class java.lang.InterruptedException
private void lambda$5(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
dup
astore 2
monitorenter
1: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
ifeq 22
2: aload 0
iconst_0
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
3: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.lockReleaseExec:Ljava/util/concurrent/ExecutorService;
invokeinterface java.util.concurrent.ExecutorService.shutdown:()V
4: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.subsMapHelper:Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
invokevirtual io.vertx.spi.cluster.hazelcast.impl.SubsMapHelper.close:()V
5: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCluster:()Lcom/hazelcast/cluster/Cluster;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.membershipListenerId:Ljava/util/UUID;
invokeinterface com.hazelcast.cluster.Cluster.removeMembershipListener:(Ljava/util/UUID;)Z
istore 3
start local 3 6: iload 3
ifne 8
7: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "No membership listener"
invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;)V
8: StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager int
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getLifecycleService:()Lcom/hazelcast/core/LifecycleService;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.lifecycleListenerId:Ljava/util/UUID;
invokeinterface com.hazelcast.core.LifecycleService.removeLifecycleListener:(Ljava/util/UUID;)Z
pop
9: goto 18
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getLifecycleService:()Lcom/hazelcast/core/LifecycleService;
invokeinterface com.hazelcast.core.LifecycleService.shutdown:()V
11: goto 14
StackMap locals:
StackMap stack: java.util.concurrent.RejectedExecutionException
12: pop
13: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/impl/logging/Logger;
ldc "Rejected execution of the shutdown operation, retrying"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
14: StackMap locals:
StackMap stack:
lconst_1
invokestatic java.lang.Thread.sleep:(J)V
15: goto 18
StackMap locals:
StackMap stack: java.lang.InterruptedException
16: pop
17: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
18: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 22
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getLifecycleService:()Lcom/hazelcast/core/LifecycleService;
invokeinterface com.hazelcast.core.LifecycleService.isRunning:()Z
ifne 10
end local 3 19: goto 22
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager io.vertx.core.Promise io.vertx.spi.cluster.hazelcast.HazelcastClusterManager
StackMap stack: java.lang.Throwable
20: astore 3
start local 3 21: aload 1
aload 3
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
end local 3 22: StackMap locals:
StackMap stack:
aload 2
monitorexit
23: goto 26
StackMap locals:
StackMap stack: java.lang.Throwable
24: aload 2
monitorexit
25: athrow
26: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.Promise.complete:()V
27: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 28 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 28 1 prom Lio/vertx/core/Promise<Ljava/lang/Void;>;
6 19 3 left Z
21 22 3 t Ljava/lang/Throwable;
Exception table:
from to target type
10 11 12 Class java.util.concurrent.RejectedExecutionException
14 15 16 Class java.lang.InterruptedException
2 19 20 Class java.lang.Throwable
1 23 24 any
24 25 24 any
private void lambda$8(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.subsMapHelper:Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
invokevirtual io.vertx.spi.cluster.hazelcast.impl.SubsMapHelper.republishOwnSubs:()V
1: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 3 1 prom Lio/vertx/core/Promise<Ljava/lang/Object;>;
private void lambda$11(java.lang.String, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 2 0: aload 2
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.subsMapHelper:Lio/vertx/spi/cluster/hazelcast/impl/SubsMapHelper;
aload 1
invokevirtual io.vertx.spi.cluster.hazelcast.impl.SubsMapHelper.get:(Ljava/lang/String;)Ljava/util/List;
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 2 2 prom Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;
private static java.lang.Thread lambda$1(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Ljava/lang/Thread;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new java.lang.Thread
dup
aload 0
ldc "vertx-hazelcast-service-release-lock-thread"
invokespecial java.lang.Thread.<init>:(Ljava/lang/Runnable;Ljava/lang/String;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 r Ljava/lang/Runnable;
}
SourceFile: "HazelcastClusterManager.java"
InnerClasses:
public final LifecycleState = com.hazelcast.core.LifecycleEvent$LifecycleState of com.hazelcast.core.LifecycleEvent
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
HazelcastClusterManager
log: Logger
<clinit>(): void
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-hazelcast: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)