public class io.vertx.spi.cluster.hazelcast.HazelcastClusterManager implements io.vertx.core.spi.cluster.ClusterManager, com.hazelcast.core.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.logging.Logger log;
descriptor: Lio/vertx/core/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 static final java.lang.String NODE_ID_ATTRIBUTE;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "__vertx.nodeId"
private static final java.lang.String OPTION_USE_HZ_ASYNC_API;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "vertx.hazelcast.async-api"
private static final boolean USE_HZ_ASYNC_API;
descriptor: Z
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0002) ACC_PRIVATE
private com.hazelcast.core.HazelcastInstance hazelcast;
descriptor: Lcom/hazelcast/core/HazelcastInstance;
flags: (0x0002) ACC_PRIVATE
private java.lang.String nodeID;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String membershipListenerId;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private java.lang.String lifecycleListenerId;
descriptor: Ljava/lang/String;
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 java.util.Set<io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMultiMap> multimaps;
descriptor: Ljava/util/Set;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Set<Lio/vertx/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap;>;
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
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.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/logging/Logger;
1: ldc "vertx.hazelcast.async-api"
invokestatic java.lang.Boolean.getBoolean:(Ljava/lang/String;)Z
putstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.USE_HZ_ASYNC_API:Z
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, 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: aload 0
new java.util.WeakHashMap
dup
iconst_1
invokespecial java.util.WeakHashMap.<init>:(I)V
invokestatic java.util.Collections.newSetFromMap:(Ljava/util/Map;)Ljava/util/Set;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.multimaps:Ljava/util/Set;
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 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=4, 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 0
new java.util.WeakHashMap
dup
iconst_1
invokespecial java.util.WeakHashMap.<init>:(I)V
invokestatic java.util.Collections.newSetFromMap:(Ljava/util/Map;)Ljava/util/Set;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.multimaps:Ljava/util/Set;
3: aload 1
ldc "The Hazelcast config cannot be null."
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 0
aload 1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
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 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=4, 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 0
new java.util.WeakHashMap
dup
iconst_1
invokespecial java.util.WeakHashMap.<init>:(I)V
invokestatic java.util.Collections.newSetFromMap:(Ljava/util/Map;)Ljava/util/Set;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.multimaps:Ljava/util/Set;
3: aload 1
ldc "The Hazelcast instance cannot be null."
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
4: aload 0
aload 1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
5: aload 0
iconst_1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 7 1 instance Lcom/hazelcast/core/HazelcastInstance;
MethodParameters:
Name Flags
instance
public void setVertx(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)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.vertx:Lio/vertx/core/Vertx;
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 vertx Lio/vertx/core/Vertx;
MethodParameters:
Name Flags
vertx
public synchronized void join(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
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/Vertx;
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.Vertx.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 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
resultHandler
public <K, V> void getAsyncMultiMap(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.spi.cluster.AsyncMultiMap<K, V>>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, 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/Vertx;
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$1(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 2
2: invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/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 name Ljava/lang/String;
0 4 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/spi/cluster/AsyncMultiMap<TK;TV;>;>;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/spi/cluster/AsyncMultiMap<TK;TV;>;>;>;)V
MethodParameters:
Name Flags
name
resultHandler
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/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=5, 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/core/Cluster;
invokeinterface com.hazelcast.core.Cluster.getMembers:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 3
goto 7
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.core.Member
astore 2
start local 2 3: aload 2
ldc "__vertx.nodeId"
invokeinterface com.hazelcast.core.Member.getStringAttribute:(Ljava/lang/String;)Ljava/lang/String;
astore 4
start local 4 4: aload 1
aload 4
ifnull 5
aload 4
goto 6
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.util.List com.hazelcast.core.Member java.util.Iterator java.lang.String
StackMap stack: java.util.List
5: aload 2
invokeinterface com.hazelcast.core.Member.getUuid:()Ljava/lang/String;
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.util.List com.hazelcast.core.Member java.util.Iterator java.lang.String
StackMap stack: java.util.List java.lang.String
6: invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 4 end local 2 7: StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.util.List top java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
8: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
1 9 1 list Ljava/util/List<Ljava/lang/String;>;
3 7 2 member Lcom/hazelcast/core/Member;
4 7 4 nodeIdAttribute Ljava/lang/String;
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 <K, V> void getAsyncMap(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.AsyncMap<K, V>>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, 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/Vertx;
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$2(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 2
2: invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/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 name Ljava/lang/String;
0 4 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;>;)V
MethodParameters:
Name Flags
name
resultHandler
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=3, 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/core/IMap;
astore 2
start local 2 1: aload 2
areturn
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;
1 2 2 map Lcom/hazelcast/core/IMap<TK;TV;>;
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.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Lock>>);
descriptor: (Ljava/lang/String;JLio/vertx/core/Handler;)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/Vertx;
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$3(Ljava/lang/String;JLio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 4
2: invokeinterface io.vertx.core.Vertx.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 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Lock;>;>;
Signature: (Ljava/lang/String;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Lock;>;>;)V
MethodParameters:
Name Flags
name
timeout
resultHandler
public void getCounter(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Counter>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, 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/Vertx;
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$4(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 2
2: invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/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 name Ljava/lang/String;
0 4 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Counter;>;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Counter;>;>;)V
MethodParameters:
Name Flags
name
resultHandler
public void leave(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)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/Vertx;
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.Vertx.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 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
resultHandler
public synchronized void memberAdded(com.hazelcast.core.MembershipEvent);
descriptor: (Lcom/hazelcast/core/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.core.MembershipEvent.getMember:()Lcom/hazelcast/core/Member;
astore 2
start local 2 3: aload 2
ldc "__vertx.nodeId"
invokeinterface com.hazelcast.core.Member.getStringAttribute:(Ljava/lang/String;)Ljava/lang/String;
astore 3
start local 3 4: aload 3
ifnonnull 6
5: aload 2
invokeinterface com.hazelcast.core.Member.getUuid:()Ljava/lang/String;
astore 3
6: StackMap locals: com.hazelcast.core.Member java.lang.String
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.multimaps:Ljava/util/Set;
invokedynamic accept()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/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap.clearCache()V (5)
(Lio/vertx/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
7: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
ifnull 13
8: 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
9: 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
10: goto 13
StackMap locals:
StackMap stack: java.lang.Throwable
11: astore 4
start local 4 12: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/logging/Logger;
ldc "Failed to handle memberAdded"
aload 4
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 4 13: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 14 1 membershipEvent Lcom/hazelcast/core/MembershipEvent;
3 14 2 member Lcom/hazelcast/core/Member;
4 14 3 memberNodeId Ljava/lang/String;
12 13 4 t Ljava/lang/Throwable;
Exception table:
from to target type
6 10 11 Class java.lang.Throwable
MethodParameters:
Name Flags
membershipEvent
public synchronized void memberRemoved(com.hazelcast.core.MembershipEvent);
descriptor: (Lcom/hazelcast/core/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.core.MembershipEvent.getMember:()Lcom/hazelcast/core/Member;
astore 2
start local 2 3: aload 2
ldc "__vertx.nodeId"
invokeinterface com.hazelcast.core.Member.getStringAttribute:(Ljava/lang/String;)Ljava/lang/String;
astore 3
start local 3 4: aload 3
ifnonnull 6
5: aload 2
invokeinterface com.hazelcast.core.Member.getUuid:()Ljava/lang/String;
astore 3
6: StackMap locals: com.hazelcast.core.Member java.lang.String
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.multimaps:Ljava/util/Set;
invokedynamic accept()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/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap.clearCache()V (5)
(Lio/vertx/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
7: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
ifnull 13
8: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeIds:Ljava/util/Set;
aload 3
invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
pop
9: 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.nodeLeft:(Ljava/lang/String;)V
10: goto 13
StackMap locals:
StackMap stack: java.lang.Throwable
11: astore 4
start local 4 12: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/logging/Logger;
ldc "Failed to handle memberRemoved"
aload 4
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 4 13: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 14 1 membershipEvent Lcom/hazelcast/core/MembershipEvent;
3 14 2 member Lcom/hazelcast/core/Member;
4 14 3 memberNodeId Ljava/lang/String;
12 13 4 t Ljava/lang/Throwable;
Exception table:
from to target type
6 10 11 Class java.lang.Throwable
MethodParameters:
Name Flags
membershipEvent
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 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.multimaps:Ljava/util/Set;
invokedynamic accept()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/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap.clearCache()V (5)
(Lio/vertx/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
3: 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 18
4: aload 0
invokevirtual io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.getNodes:()Ljava/util/List;
astore 2
start local 2 5: new java.util.HashSet
dup
aload 2
invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
astore 3
start local 3 6: 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
7: 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 8: aload 4
aload 2
invokeinterface java.util.Set.removeAll:(Ljava/util/Collection;)Z
pop
9: aload 3
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 12
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:
10: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 5
start local 5 11: 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 12: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
13: aload 4
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 16
StackMap locals:
StackMap stack:
14: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 5
start local 5 15: 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.nodeLeft:(Ljava/lang/String;)V
end local 5 16: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
17: 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 18: 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 19 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 19 1 lifecycleEvent Lcom/hazelcast/core/LifecycleEvent;
5 18 2 currentNodes Ljava/util/List<Ljava/lang/String;>;
6 18 3 newNodes Ljava/util/Set<Ljava/lang/String;>;
8 18 4 removedMembers Ljava/util/Set<Ljava/lang/String;>;
11 12 5 nodeId Ljava/lang/String;
15 16 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 memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent);
descriptor: (Lcom/hazelcast/core/MemberAttributeEvent;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
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 memberAttributeEvent Lcom/hazelcast/core/MemberAttributeEvent;
MethodParameters:
Name Flags
memberAttributeEvent
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=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
ifne 16
1: aload 0
iconst_1
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.active:Z
2: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 10
3: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
ifnonnull 8
4: 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;
5: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.conf:Lcom/hazelcast/config/Config;
ifnonnull 8
6: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/logging/Logger;
ldc "Cannot find cluster configuration on 'vertx.hazelcast.config' system property, on the classpath, or specified programmatically. Using default hazelcast configuration"
invokevirtual io.vertx.core.logging.Logger.warn:(Ljava/lang/Object;)V
7: 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;
8: 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
9: 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;
10: 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/core/Cluster;
invokeinterface com.hazelcast.core.Cluster.getLocalMember:()Lcom/hazelcast/core/Member;
astore 2
start local 2 11: aload 0
aload 2
invokeinterface com.hazelcast.core.Member.getUuid:()Ljava/lang/String;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeID:Ljava/lang/String;
12: aload 2
ldc "__vertx.nodeId"
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.nodeID:Ljava/lang/String;
invokeinterface com.hazelcast.core.Member.setStringAttribute:(Ljava/lang/String;Ljava/lang/String;)V
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/core/Cluster;
aload 0
invokeinterface com.hazelcast.core.Cluster.addMembershipListener:(Lcom/hazelcast/core/MembershipListener;)Ljava/lang/String;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.membershipListenerId:Ljava/lang/String;
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/lang/String;
putfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.lifecycleListenerId:Ljava/lang/String;
15: aload 1
invokeinterface io.vertx.core.Promise.complete:()V
end local 2 16: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 17 1 fut Lio/vertx/core/Promise<Ljava/lang/Void;>;
11 16 2 localMember Lcom/hazelcast/core/Member;
private void lambda$1(java.lang.String, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=6, args_size=3
start local 0 start local 2 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
aload 1
invokeinterface com.hazelcast.core.HazelcastInstance.getMultiMap:(Ljava/lang/String;)Lcom/hazelcast/core/MultiMap;
astore 3
start local 3 1: new io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMultiMap
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/Vertx;
aload 3
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMultiMap.<init>:(Lio/vertx/core/Vertx;Lcom/hazelcast/core/MultiMap;)V
astore 4
start local 4 2: aload 0
dup
astore 5
monitorenter
3: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.multimaps:Ljava/util/Set;
aload 4
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
4: aload 5
monitorexit
5: goto 8
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.lang.String io.vertx.core.Promise com.hazelcast.core.MultiMap io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMultiMap io.vertx.spi.cluster.hazelcast.HazelcastClusterManager
StackMap stack: java.lang.Throwable
6: aload 5
monitorexit
7: athrow
8: StackMap locals:
StackMap stack:
aload 2
aload 4
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 4 end local 3 9: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 10 2 fut Lio/vertx/core/Promise<Lio/vertx/core/spi/cluster/AsyncMultiMap<TK;TV;>;>;
1 9 3 multiMap Lcom/hazelcast/core/MultiMap<TK;TV;>;
2 9 4 asyncMultiMap Lio/vertx/spi/cluster/hazelcast/impl/HazelcastAsyncMultiMap<TK;TV;>;
Exception table:
from to target type
3 5 6 any
6 7 6 any
private void lambda$2(java.lang.String, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 2 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/core/IMap;
astore 3
start local 3 1: aload 2
getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.USE_HZ_ASYNC_API:Z
ifeq 2
new io.vertx.spi.cluster.hazelcast.impl.HazelcastInternalAsyncMap
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/Vertx;
aload 3
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastInternalAsyncMap.<init>:(Lio/vertx/core/Vertx;Lcom/hazelcast/core/IMap;)V
goto 3
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.lang.String io.vertx.core.Promise com.hazelcast.core.IMap
StackMap stack: io.vertx.core.Promise
2: new io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMap
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/Vertx;
aload 3
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastAsyncMap.<init>:(Lio/vertx/core/Vertx;Lcom/hazelcast/core/IMap;)V
StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.lang.String io.vertx.core.Promise com.hazelcast.core.IMap
StackMap stack: io.vertx.core.Promise io.vertx.core.shareddata.AsyncMap
3: invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 4: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 5 2 fut Lio/vertx/core/Promise<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;
1 4 3 map Lcom/hazelcast/core/IMap<TK;TV;>;
private void lambda$3(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;
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.core.HazelcastInstance.getSemaphore:(Ljava/lang/String;)Lcom/hazelcast/core/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.core.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.core.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.core.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.HazelcastClusterManager$HazelcastLock
dup
aload 0
aload 5
invokespecial io.vertx.spi.cluster.hazelcast.HazelcastClusterManager$HazelcastLock.<init>:(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;Lcom/hazelcast/core/ISemaphore;)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 fut Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;
1 14 5 iSemaphore Lcom/hazelcast/core/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$4(java.lang.String, io.vertx.core.Promise);
descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 2 0: aload 2
1: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.USE_HZ_ASYNC_API:Z
ifeq 3
2: new io.vertx.spi.cluster.hazelcast.impl.HazelcastInternalAsyncCounter
dup
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.vertx:Lio/vertx/core/Vertx;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
aload 1
invokeinterface com.hazelcast.core.HazelcastInstance.getAtomicLong:(Ljava/lang/String;)Lcom/hazelcast/core/IAtomicLong;
invokespecial io.vertx.spi.cluster.hazelcast.impl.HazelcastInternalAsyncCounter.<init>:(Lio/vertx/core/Vertx;Lcom/hazelcast/core/IAtomicLong;)V
goto 4
3: StackMap locals:
StackMap stack: io.vertx.core.Promise
new io.vertx.spi.cluster.hazelcast.HazelcastClusterManager$HazelcastCounter
dup
aload 0
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
aload 1
invokeinterface com.hazelcast.core.HazelcastInstance.getAtomicLong:(Ljava/lang/String;)Lcom/hazelcast/core/IAtomicLong;
invokespecial io.vertx.spi.cluster.hazelcast.HazelcastClusterManager$HazelcastCounter.<init>:(Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;Lcom/hazelcast/core/IAtomicLong;)V
4: StackMap locals: io.vertx.spi.cluster.hazelcast.HazelcastClusterManager java.lang.String io.vertx.core.Promise
StackMap stack: io.vertx.core.Promise io.vertx.core.shareddata.Counter
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
5: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/hazelcast/HazelcastClusterManager;
0 6 2 fut Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Counter;>;
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.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCluster:()Lcom/hazelcast/core/Cluster;
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.membershipListenerId:Ljava/lang/String;
invokeinterface com.hazelcast.core.Cluster.removeMembershipListener:(Ljava/lang/String;)Z
istore 3
start local 3 4: iload 3
ifne 6
5: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/logging/Logger;
ldc "No membership listener"
invokevirtual io.vertx.core.logging.Logger.warn:(Ljava/lang/Object;)V
6: 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/lang/String;
invokeinterface com.hazelcast.core.LifecycleService.removeLifecycleListener:(Ljava/lang/String;)Z
pop
7: goto 16
8: 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
9: goto 12
StackMap locals:
StackMap stack: java.util.concurrent.RejectedExecutionException
10: pop
11: getstatic io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.log:Lio/vertx/core/logging/Logger;
ldc "Rejected execution of the shutdown operation, retrying"
invokevirtual io.vertx.core.logging.Logger.debug:(Ljava/lang/Object;)V
12: StackMap locals:
StackMap stack:
lconst_1
invokestatic java.lang.Thread.sleep:(J)V
13: goto 16
StackMap locals:
StackMap stack: java.lang.InterruptedException
14: pop
15: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
16: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifne 17
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 8
17: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.customHazelcastCluster:Z
ifeq 22
18: aload 0
getfield io.vertx.spi.cluster.hazelcast.HazelcastClusterManager.hazelcast:Lcom/hazelcast/core/HazelcastInstance;
invokeinterface com.hazelcast.core.HazelcastInstance.getCluster:()Lcom/hazelcast/core/Cluster;
invokeinterface com.hazelcast.core.Cluster.getLocalMember:()Lcom/hazelcast/core/Member;
ldc "__vertx.nodeId"
invokeinterface com.hazelcast.core.Member.removeAttribute:(Ljava/lang/String;)V
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 fut Lio/vertx/core/Promise<Ljava/lang/Void;>;
4 19 3 left Z
21 22 3 t Ljava/lang/Throwable;
Exception table:
from to target type
8 9 10 Class java.util.concurrent.RejectedExecutionException
12 13 14 Class java.lang.InterruptedException
2 19 20 Class java.lang.Throwable
1 23 24 any
24 25 24 any
}
SourceFile: "HazelcastClusterManager.java"
NestMembers:
io.vertx.spi.cluster.hazelcast.HazelcastClusterManager$HazelcastCounter io.vertx.spi.cluster.hazelcast.HazelcastClusterManager$HazelcastLock
InnerClasses:
public final LifecycleState = com.hazelcast.core.LifecycleEvent$LifecycleState of com.hazelcast.core.LifecycleEvent
private HazelcastCounter = io.vertx.spi.cluster.hazelcast.HazelcastClusterManager$HazelcastCounter of io.vertx.spi.cluster.hazelcast.HazelcastClusterManager
private HazelcastLock = io.vertx.spi.cluster.hazelcast.HazelcastClusterManager$HazelcastLock of io.vertx.spi.cluster.hazelcast.HazelcastClusterManager
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles