public class io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer
super_class: java.lang.Object
{
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.TaskQueue taskQueue;
descriptor: Lio/vertx/core/impl/TaskQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private void <init>(io.vertx.core.impl.VertxInternal);
descriptor: (Lio/vertx/core/impl/VertxInternal;)V
flags: (0x0002) ACC_PRIVATE
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
aload 1
putfield io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.vertx:Lio/vertx/core/impl/VertxInternal;
2: aload 0
new io.vertx.core.impl.TaskQueue
dup
invokespecial io.vertx.core.impl.TaskQueue.<init>:()V
putfield io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.taskQueue:Lio/vertx/core/impl/TaskQueue;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
0 4 1 vertx Lio/vertx/core/impl/VertxInternal;
MethodParameters:
Name Flags
vertx
public static io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer get(io.vertx.core.impl.ContextInternal);
descriptor: (Lio/vertx/core/impl/ContextInternal;)Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=5, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.impl.ContextInternal.contextData:()Ljava/util/concurrent/ConcurrentMap;
astore 1
start local 1 1: aload 1
ldc Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer
astore 2
start local 2 2: aload 2
ifnonnull 8
3: new io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer
dup
aload 0
invokeinterface io.vertx.core.impl.ContextInternal.owner:()Lio/vertx/core/impl/VertxInternal;
invokespecial io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.<init>:(Lio/vertx/core/impl/VertxInternal;)V
astore 3
start local 3 4: aload 1
ldc Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
aload 3
invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer
astore 4
start local 4 5: aload 4
ifnonnull 6
aload 3
goto 7
StackMap locals: io.vertx.core.impl.ContextInternal java.util.concurrent.ConcurrentMap io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer
StackMap stack:
6: aload 4
StackMap locals:
StackMap stack: io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer
7: astore 2
end local 4 end local 3 8: StackMap locals:
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 context Lio/vertx/core/impl/ContextInternal;
1 9 1 contextData Ljava/util/concurrent/ConcurrentMap<Ljava/lang/Object;Ljava/lang/Object;>;
2 9 2 instance Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
4 8 3 candidate Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
5 8 4 previous Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
MethodParameters:
Name Flags
context
public void execute(java.util.function.BiConsumer<java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo>, java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo, io.vertx.core.Promise<java.lang.Void>);
descriptor: (Ljava/util/function/BiConsumer;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=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.taskQueue:Lio/vertx/core/impl/TaskQueue;
aload 1
aload 2
aload 3
aload 4
invokedynamic run(Ljava/util/function/BiConsumer;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)Ljava/lang/Runnable;
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:
()V
io/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer.lambda$0(Ljava/util/function/BiConsumer;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V (6)
()V
1: aload 0
getfield io.vertx.spi.cluster.hazelcast.impl.SubsOpSerializer.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getWorkerPool:()Ljava/util/concurrent/ExecutorService;
2: invokevirtual io.vertx.core.impl.TaskQueue.execute:(Ljava/lang/Runnable;Ljava/util/concurrent/Executor;)V
3: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/hazelcast/impl/SubsOpSerializer;
0 4 1 op Ljava/util/function/BiConsumer<Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;>;
0 4 2 address Ljava/lang/String;
0 4 3 registrationInfo Lio/vertx/core/spi/cluster/RegistrationInfo;
0 4 4 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (Ljava/util/function/BiConsumer<Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;>;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
MethodParameters:
Name Flags
op
address
registrationInfo
promise
private static void lambda$0(java.util.function.BiConsumer, java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo, io.vertx.core.Promise);
descriptor: (Ljava/util/function/BiConsumer;Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;Lio/vertx/core/Promise;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=4
0: aload 0
aload 1
aload 2
invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 3
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 5
StackMap locals:
StackMap stack: java.lang.Exception
3: astore 4
start local 4 4: aload 3
aload 4
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
end local 4 5: StackMap locals:
StackMap stack:
return
LocalVariableTable:
Start End Slot Name Signature
4 5 4 e Ljava/lang/Exception;
Exception table:
from to target type
0 2 3 Class java.lang.Exception
}
SourceFile: "SubsOpSerializer.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles