public class io.vertx.redis.client.impl.RedisSentinelClient implements io.vertx.redis.client.Redis
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.redis.client.impl.RedisSentinelClient
super_class: java.lang.Object
{
private static final java.util.Random RANDOM;
descriptor: Ljava/util/Random;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final io.vertx.core.logging.Logger LOG;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.redis.client.RedisOptions options;
descriptor: Lio/vertx/redis/client/RedisOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private io.vertx.redis.client.Redis sentinel;
descriptor: Lio/vertx/redis/client/Redis;
flags: (0x0002) ACC_PRIVATE
private io.vertx.redis.client.impl.RedisClient redis;
descriptor: Lio/vertx/redis/client/impl/RedisClient;
flags: (0x0002) ACC_PRIVATE
private static volatile int[] $SWITCH_TABLE$io$vertx$redis$client$RedisRole;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new java.util.Random
dup
invokespecial java.util.Random.<init>:()V
putstatic io.vertx.redis.client.impl.RedisSentinelClient.RANDOM:Ljava/util/Random;
1: ldc Lio/vertx/redis/client/impl/RedisSentinelClient;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.redis.client.impl.RedisSentinelClient.LOG:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>(io.vertx.core.Vertx, io.vertx.redis.client.RedisOptions);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.redis.client.impl.RedisSentinelClient.vertx:Lio/vertx/core/Vertx;
2: aload 0
aload 2
putfield io.vertx.redis.client.impl.RedisSentinelClient.options:Lio/vertx/redis/client/RedisOptions;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 4 1 vertx Lio/vertx/core/Vertx;
0 4 2 options Lio/vertx/redis/client/RedisOptions;
MethodParameters:
Name Flags
vertx
options
public io.vertx.redis.client.Redis connect(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.redis.client.Redis>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.vertx:Lio/vertx/core/Vertx;
aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.options:Lio/vertx/redis/client/RedisOptions;
getstatic io.vertx.redis.client.RedisRole.SENTINEL:Lio/vertx/redis/client/RedisRole;
aload 0
invokedynamic handle(Lio/vertx/redis/client/impl/RedisSentinelClient;)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/redis/client/impl/RedisSentinelClient.lambda$0(Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokestatic io.vertx.redis.client.impl.RedisSentinelClient.createClientInternal:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/redis/client/RedisRole;Lio/vertx/core/Handler;)V
1: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.vertx:Lio/vertx/core/Vertx;
aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.options:Lio/vertx/redis/client/RedisOptions;
aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.options:Lio/vertx/redis/client/RedisOptions;
invokevirtual io.vertx.redis.client.RedisOptions.getRole:()Lio/vertx/redis/client/RedisRole;
aload 0
aload 1
invokedynamic handle(Lio/vertx/redis/client/impl/RedisSentinelClient;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/redis/client/impl/RedisSentinelClient.lambda$4(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokestatic io.vertx.redis.client.impl.RedisSentinelClient.createClientInternal:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/redis/client/RedisRole;Lio/vertx/core/Handler;)V
2: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 3 1 onCreate Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;>;)Lio/vertx/redis/client/Redis;
MethodParameters:
Name Flags
onCreate
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.sentinel:Lio/vertx/redis/client/Redis;
invokeinterface io.vertx.redis.client.Redis.close:()V
1: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
invokevirtual io.vertx.redis.client.impl.RedisClient.close:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
public io.vertx.redis.client.Redis exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
aload 1
invokevirtual io.vertx.redis.client.impl.RedisClient.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/redis/client/Redis;
MethodParameters:
Name Flags
handler
public io.vertx.redis.client.Redis endHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
aload 1
invokevirtual io.vertx.redis.client.impl.RedisClient.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/redis/client/Redis;
MethodParameters:
Name Flags
handler
public io.vertx.redis.client.Redis handler(io.vertx.core.Handler<io.vertx.redis.client.Response>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
aload 1
invokevirtual io.vertx.redis.client.impl.RedisClient.handler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/redis/client/Response;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/redis/client/Response;>;)Lio/vertx/redis/client/Redis;
MethodParameters:
Name Flags
handler
public io.vertx.redis.client.Redis pause();
descriptor: ()Lio/vertx/redis/client/Redis;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
invokevirtual io.vertx.redis.client.impl.RedisClient.pause:()Lio/vertx/redis/client/Redis;
pop
1: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
public io.vertx.redis.client.Redis resume();
descriptor: ()Lio/vertx/redis/client/Redis;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
invokevirtual io.vertx.redis.client.impl.RedisClient.resume:()Lio/vertx/redis/client/Redis;
pop
1: aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
public io.vertx.redis.client.Redis send(io.vertx.redis.client.Request, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.redis.client.Response>>);
descriptor: (Lio/vertx/redis/client/Request;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
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.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
aload 1
aload 2
invokevirtual io.vertx.redis.client.impl.RedisClient.send:(Lio/vertx/redis/client/Request;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 2 1 command Lio/vertx/redis/client/Request;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Response;>;>;
Signature: (Lio/vertx/redis/client/Request;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Response;>;>;)Lio/vertx/redis/client/Redis;
MethodParameters:
Name Flags
command
handler
public io.vertx.redis.client.Redis batch(java.util.List<io.vertx.redis.client.Request>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.redis.client.Response>>>);
descriptor: (Ljava/util/List;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
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.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
aload 1
aload 2
invokevirtual io.vertx.redis.client.impl.RedisClient.batch:(Ljava/util/List;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 2 1 commands Ljava/util/List<Lio/vertx/redis/client/Request;>;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/redis/client/Response;>;>;>;
Signature: (Ljava/util/List<Lio/vertx/redis/client/Request;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/redis/client/Response;>;>;>;)Lio/vertx/redis/client/Redis;
MethodParameters:
Name Flags
commands
handler
public io.vertx.core.net.SocketAddress socketAddress();
descriptor: ()Lio/vertx/core/net/SocketAddress;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
invokevirtual io.vertx.redis.client.impl.RedisClient.socketAddress:()Lio/vertx/core/net/SocketAddress;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
public io.vertx.redis.client.Redis fetch(long);
descriptor: (J)Lio/vertx/redis/client/Redis;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
lload 1
invokevirtual io.vertx.redis.client.impl.RedisClient.fetch:(J)Lio/vertx/redis/client/Redis;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 2 1 amount J
MethodParameters:
Name Flags
amount
public static io.vertx.redis.client.Redis create(io.vertx.core.Vertx, io.vertx.redis.client.RedisOptions);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;)Lio/vertx/redis/client/Redis;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.vertx.redis.client.impl.RedisSentinelClient
dup
aload 0
aload 1
invokespecial io.vertx.redis.client.impl.RedisSentinelClient.<init>:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 options Lio/vertx/redis/client/RedisOptions;
MethodParameters:
Name Flags
vertx
options
private static void createClientInternal(io.vertx.core.Vertx, io.vertx.redis.client.RedisOptions, io.vertx.redis.client.RedisRole, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.redis.client.Redis>>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/redis/client/RedisRole;Lio/vertx/core/Handler;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;)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/redis/client/impl/RedisSentinelClient.lambda$5(Lio/vertx/core/Handler;Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
astore 4
start local 4 1: invokestatic io.vertx.redis.client.impl.RedisSentinelClient.$SWITCH_TABLE$io$vertx$redis$client$RedisRole:()[I
aload 2
invokevirtual io.vertx.redis.client.RedisRole.ordinal:()I
iaload
tableswitch { // 1 - 3
1: 4
2: 6
3: 2
default: 7
}
2: StackMap locals: io.vertx.core.Handler
StackMap stack:
aload 0
invokedynamic resolve()Lio/vertx/redis/client/impl/Resolver;
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:
(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
io/vertx/redis/client/impl/RedisSentinelClient.isSentinelOk(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V (6)
(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
aload 1
aload 4
invokestatic io.vertx.redis.client.impl.RedisSentinelClient.resolveClient:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
3: goto 7
4: StackMap locals:
StackMap stack:
aload 0
invokedynamic resolve()Lio/vertx/redis/client/impl/Resolver;
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:
(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
io/vertx/redis/client/impl/RedisSentinelClient.getMasterFromEndpoint(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V (6)
(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
aload 1
aload 4
invokestatic io.vertx.redis.client.impl.RedisSentinelClient.resolveClient:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 0
invokedynamic resolve()Lio/vertx/redis/client/impl/Resolver;
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:
(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
io/vertx/redis/client/impl/RedisSentinelClient.getSlaveFromEndpoint(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V (6)
(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
aload 1
aload 4
invokestatic io.vertx.redis.client.impl.RedisSentinelClient.resolveClient:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
7: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 vertx Lio/vertx/core/Vertx;
0 8 1 options Lio/vertx/redis/client/RedisOptions;
0 8 2 role Lio/vertx/redis/client/RedisRole;
0 8 3 onCreate Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;>;
1 8 4 createAndConnect Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/redis/client/RedisRole;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;>;)V
MethodParameters:
Name Flags
vertx
options
role
onCreate
private static void resolveClient(io.vertx.core.Vertx, io.vertx.redis.client.impl.Resolver, io.vertx.redis.client.RedisOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.net.SocketAddress>>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iconst_0
aload 0
aload 1
aload 2
aload 3
aload 2
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;)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/redis/client/impl/RedisSentinelClient.lambda$9(Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokestatic io.vertx.redis.client.impl.RedisSentinelClient.iterate:(ILio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 vertx Lio/vertx/core/Vertx;
0 2 1 checkEndpointFn Lio/vertx/redis/client/impl/Resolver;
0 2 2 options Lio/vertx/redis/client/RedisOptions;
0 2 3 callback Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;)V
MethodParameters:
Name Flags
vertx final
checkEndpointFn final
options final
callback final
private static void iterate(int, io.vertx.core.Vertx, io.vertx.redis.client.impl.Resolver, io.vertx.redis.client.RedisOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.redis.client.impl.RedisSentinelClient$Pair<java.lang.Integer, io.vertx.core.net.SocketAddress>>>);
descriptor: (ILio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=9, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 3
invokevirtual io.vertx.redis.client.RedisOptions.getEndpoints:()Ljava/util/List;
astore 5
start local 5 1: iload 0
aload 5
invokeinterface java.util.List.size:()I
if_icmplt 4
2: aload 4
ldc "No more endpoints in chain."
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: return
4: StackMap locals: java.util.List
StackMap stack:
aload 2
aload 1
aload 5
iload 0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.net.SocketAddress
aload 3
aload 4
iload 0
aload 1
aload 2
aload 3
invokedynamic handle(Lio/vertx/core/Handler;ILio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;)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/redis/client/impl/RedisSentinelClient.lambda$10(Lio/vertx/core/Handler;ILio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.impl.Resolver.resolve:(Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
5: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 idx I
0 6 1 vertx Lio/vertx/core/Vertx;
0 6 2 checkEndpointFn Lio/vertx/redis/client/impl/Resolver;
0 6 3 argument Lio/vertx/redis/client/RedisOptions;
0 6 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/impl/RedisSentinelClient$Pair<Ljava/lang/Integer;Lio/vertx/core/net/SocketAddress;>;>;>;
1 6 5 endpoints Ljava/util/List<Lio/vertx/core/net/SocketAddress;>;
Signature: (ILio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/impl/RedisSentinelClient$Pair<Ljava/lang/Integer;Lio/vertx/core/net/SocketAddress;>;>;>;)V
MethodParameters:
Name Flags
idx final
vertx final
checkEndpointFn final
argument final
resultHandler final
private static void isSentinelOk(io.vertx.core.Vertx, io.vertx.core.net.SocketAddress, io.vertx.redis.client.RedisOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.net.SocketAddress>>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
aload 1
invokestatic io.vertx.redis.client.impl.RedisClient.create:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/net/SocketAddress;)Lio/vertx/redis/client/Redis;
aload 3
aload 1
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/net/SocketAddress;)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/redis/client/impl/RedisSentinelClient.lambda$11(Lio/vertx/core/Handler;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.Redis.connect:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 vertx Lio/vertx/core/Vertx;
0 2 1 endpoint Lio/vertx/core/net/SocketAddress;
0 2 2 argument Lio/vertx/redis/client/RedisOptions;
0 2 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;)V
MethodParameters:
Name Flags
vertx
endpoint
argument
handler
private static void getMasterFromEndpoint(io.vertx.core.Vertx, io.vertx.core.net.SocketAddress, io.vertx.redis.client.RedisOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.net.SocketAddress>>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
aload 1
invokestatic io.vertx.redis.client.impl.RedisClient.create:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/net/SocketAddress;)Lio/vertx/redis/client/Redis;
aload 3
aload 2
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;)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/redis/client/impl/RedisSentinelClient.lambda$13(Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.Redis.connect:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 vertx Lio/vertx/core/Vertx;
0 2 1 endpoint Lio/vertx/core/net/SocketAddress;
0 2 2 options Lio/vertx/redis/client/RedisOptions;
0 2 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;)V
MethodParameters:
Name Flags
vertx
endpoint
options
handler
private static void getSlaveFromEndpoint(io.vertx.core.Vertx, io.vertx.core.net.SocketAddress, io.vertx.redis.client.RedisOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.net.SocketAddress>>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
aload 1
invokestatic io.vertx.redis.client.impl.RedisClient.create:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/net/SocketAddress;)Lio/vertx/redis/client/Redis;
aload 3
aload 2
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;)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/redis/client/impl/RedisSentinelClient.lambda$15(Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.Redis.connect:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 vertx Lio/vertx/core/Vertx;
0 2 1 endpoint Lio/vertx/core/net/SocketAddress;
0 2 2 options Lio/vertx/redis/client/RedisOptions;
0 2 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;>;)V
MethodParameters:
Name Flags
vertx
endpoint
options
handler
public io.vertx.core.streams.ReadStream pause();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.redis.client.impl.RedisSentinelClient.pause:()Lio/vertx/redis/client/Redis;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream handler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.Handler
invokevirtual io.vertx.redis.client.impl.RedisSentinelClient.handler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream endHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.redis.client.impl.RedisSentinelClient.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream resume();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.redis.client.impl.RedisSentinelClient.resume:()Lio/vertx/redis/client/Redis;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream fetch(long);
descriptor: (J)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
0: aload 0
lload 1
invokevirtual io.vertx.redis.client.impl.RedisSentinelClient.fetch:(J)Lio/vertx/redis/client/Redis;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.StreamBase exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/StreamBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.redis.client.impl.RedisSentinelClient.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.redis.client.impl.RedisSentinelClient.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
areturn
LocalVariableTable:
Start End Slot Name Signature
static int[] $SWITCH_TABLE$io$vertx$redis$client$RedisRole();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic io.vertx.redis.client.impl.RedisSentinelClient.$SWITCH_TABLE$io$vertx$redis$client$RedisRole:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic io.vertx.redis.client.RedisRole.values:()[Lio/vertx/redis/client/RedisRole;
arraylength
newarray 10
astore 0
2: aload 0
getstatic io.vertx.redis.client.RedisRole.MASTER:Lio/vertx/redis/client/RedisRole;
invokevirtual io.vertx.redis.client.RedisRole.ordinal:()I
iconst_1
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic io.vertx.redis.client.RedisRole.SENTINEL:Lio/vertx/redis/client/RedisRole;
invokevirtual io.vertx.redis.client.RedisRole.ordinal:()I
iconst_3
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic io.vertx.redis.client.RedisRole.SLAVE:Lio/vertx/redis/client/RedisRole;
invokevirtual io.vertx.redis.client.RedisRole.ordinal:()I
iconst_2
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
dup
putstatic io.vertx.redis.client.impl.RedisSentinelClient.$SWITCH_TABLE$io$vertx$redis$client$RedisRole:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
8 9 10 Class java.lang.NoSuchFieldError
private void lambda$0(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: getstatic io.vertx.redis.client.impl.RedisSentinelClient.LOG:Lio/vertx/core/logging/Logger;
ldc "Redis PUB/SUB wrap failed."
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
2: return
3: StackMap locals:
StackMap stack:
aload 0
aload 1
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.Redis
putfield io.vertx.redis.client.impl.RedisSentinelClient.sentinel:Lio/vertx/redis/client/Redis;
4: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.sentinel:Lio/vertx/redis/client/Redis;
5: aload 0
invokedynamic handle(Lio/vertx/redis/client/impl/RedisSentinelClient;)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/redis/client/impl/RedisSentinelClient.lambda$1(Lio/vertx/redis/client/Response;)V (7)
(Lio/vertx/redis/client/Response;)V
invokeinterface io.vertx.redis.client.Redis.handler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
6: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.sentinel:Lio/vertx/redis/client/Redis;
getstatic io.vertx.redis.client.Command.SUBSCRIBE:Lio/vertx/redis/client/Command;
invokestatic io.vertx.redis.client.Request.cmd:(Lio/vertx/redis/client/Command;)Lio/vertx/redis/client/Request;
ldc "+switch-master"
invokeinterface io.vertx.redis.client.Request.arg:(Ljava/lang/String;)Lio/vertx/redis/client/Request;
aload 0
invokedynamic handle(Lio/vertx/redis/client/impl/RedisSentinelClient;)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/redis/client/impl/RedisSentinelClient.lambda$2(Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.Redis.send:(Lio/vertx/redis/client/Request;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
7: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.sentinel:Lio/vertx/redis/client/Redis;
aload 0
invokedynamic handle(Lio/vertx/redis/client/impl/RedisSentinelClient;)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/redis/client/impl/RedisSentinelClient.lambda$3(Ljava/lang/Throwable;)V (7)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.redis.client.Redis.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 9 1 create Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;
private void lambda$4(io.vertx.core.Handler, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 1
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.impl.RedisClient
putfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
4: aload 1
aload 0
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 6 2 create Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;
private static void lambda$5(io.vertx.core.Handler, io.vertx.core.Vertx, io.vertx.redis.client.RedisOptions, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 3
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 1
aload 2
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.net.SocketAddress
invokestatic io.vertx.redis.client.impl.RedisClient.create:(Lio/vertx/core/Vertx;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/net/SocketAddress;)Lio/vertx/redis/client/Redis;
aload 0
invokeinterface io.vertx.redis.client.Redis.connect:(Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
4: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 5 3 resolve Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;
private static void lambda$9(io.vertx.core.Handler, io.vertx.redis.client.RedisOptions, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=6, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 9
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.impl.RedisSentinelClient$Pair
astore 3
start local 3 4: aload 1
invokevirtual io.vertx.redis.client.RedisOptions.getEndpoints:()Ljava/util/List;
astore 4
start local 4 5: aload 4
aload 3
getfield io.vertx.redis.client.impl.RedisSentinelClient$Pair.left:Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.net.SocketAddress
astore 5
start local 5 6: aload 4
aload 3
getfield io.vertx.redis.client.impl.RedisSentinelClient$Pair.left:Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
aload 4
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.net.SocketAddress
invokeinterface java.util.List.set:(ILjava/lang/Object;)Ljava/lang/Object;
pop
7: aload 4
iconst_0
aload 5
invokeinterface java.util.List.set:(ILjava/lang/Object;)Ljava/lang/Object;
pop
8: aload 0
aload 3
getfield io.vertx.redis.client.impl.RedisSentinelClient$Pair.right:Ljava/lang/Object;
checkcast io.vertx.core.net.SocketAddress
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 5 end local 4 end local 3 9: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 10 2 iterate Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/impl/RedisSentinelClient$Pair<Ljava/lang/Integer;Lio/vertx/core/net/SocketAddress;>;>;
4 9 3 found Lio/vertx/redis/client/impl/RedisSentinelClient$Pair<Ljava/lang/Integer;Lio/vertx/core/net/SocketAddress;>;
5 9 4 endpoints Ljava/util/List<Lio/vertx/core/net/SocketAddress;>;
6 9 5 endpoint Lio/vertx/core/net/SocketAddress;
private static void lambda$10(io.vertx.core.Handler, int, io.vertx.core.Vertx, io.vertx.redis.client.impl.Resolver, io.vertx.redis.client.RedisOptions, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;ILio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=6, args_size=6
start local 5 0: aload 5
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: aload 0
new io.vertx.redis.client.impl.RedisSentinelClient$Pair
dup
iload 1
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aload 5
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.net.SocketAddress
invokespecial io.vertx.redis.client.impl.RedisSentinelClient$Pair.<init>:(Ljava/lang/Object;Ljava/lang/Object;)V
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
iload 1
iconst_1
iadd
aload 2
aload 3
aload 4
aload 0
invokestatic io.vertx.redis.client.impl.RedisSentinelClient.iterate:(ILio/vertx/core/Vertx;Lio/vertx/redis/client/impl/Resolver;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/Handler;)V
4: StackMap locals:
StackMap stack:
return
end local 5 LocalVariableTable:
Start End Slot Name Signature
0 5 5 res Lio/vertx/core/AsyncResult<Lio/vertx/core/net/SocketAddress;>;
private static void lambda$11(io.vertx.core.Handler, io.vertx.core.net.SocketAddress, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/net/SocketAddress;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.Redis
astore 3
start local 3 4: aload 3
getstatic io.vertx.redis.client.Command.PING:Lio/vertx/redis/client/Command;
invokestatic io.vertx.redis.client.Request.cmd:(Lio/vertx/redis/client/Command;)Lio/vertx/redis/client/Request;
aload 0
aload 1
aload 3
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/Redis;)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/redis/client/impl/RedisSentinelClient.lambda$12(Lio/vertx/core/Handler;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/Redis;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.Redis.send:(Lio/vertx/redis/client/Request;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
end local 3 5: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 6 2 onCreate Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;
4 5 3 conn Lio/vertx/redis/client/Redis;
private static void lambda$13(io.vertx.core.Handler, io.vertx.redis.client.RedisOptions, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.Redis
astore 3
start local 3 4: aload 1
invokevirtual io.vertx.redis.client.RedisOptions.getMasterName:()Ljava/lang/String;
astore 4
start local 4 5: aload 3
getstatic io.vertx.redis.client.Command.SENTINEL:Lio/vertx/redis/client/Command;
invokestatic io.vertx.redis.client.Request.cmd:(Lio/vertx/redis/client/Command;)Lio/vertx/redis/client/Request;
ldc "GET-MASTER-ADDR-BY-NAME"
invokeinterface io.vertx.redis.client.Request.arg:(Ljava/lang/String;)Lio/vertx/redis/client/Request;
aload 4
invokeinterface io.vertx.redis.client.Request.arg:(Ljava/lang/String;)Lio/vertx/redis/client/Request;
aload 0
aload 3
invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/redis/client/Redis;)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/redis/client/impl/RedisSentinelClient.lambda$14(Lio/vertx/core/Handler;Lio/vertx/redis/client/Redis;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.Redis.send:(Lio/vertx/redis/client/Request;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
end local 4 end local 3 6: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 7 2 onCreate Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;
4 6 3 conn Lio/vertx/redis/client/Redis;
5 6 4 masterName Ljava/lang/String;
private static void lambda$15(io.vertx.core.Handler, io.vertx.redis.client.RedisOptions, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/redis/client/RedisOptions;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.Redis
astore 3
start local 3 4: aload 1
invokevirtual io.vertx.redis.client.RedisOptions.getMasterName:()Ljava/lang/String;
astore 4
start local 4 5: aload 3
getstatic io.vertx.redis.client.Command.SENTINEL:Lio/vertx/redis/client/Command;
invokestatic io.vertx.redis.client.Request.cmd:(Lio/vertx/redis/client/Command;)Lio/vertx/redis/client/Request;
ldc "SLAVES"
invokeinterface io.vertx.redis.client.Request.arg:(Ljava/lang/String;)Lio/vertx/redis/client/Request;
aload 4
invokeinterface io.vertx.redis.client.Request.arg:(Ljava/lang/String;)Lio/vertx/redis/client/Request;
aload 0
aload 4
aload 3
invokedynamic handle(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/redis/client/Redis;)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/redis/client/impl/RedisSentinelClient.lambda$16(Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/redis/client/Redis;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.redis.client.Redis.send:(Lio/vertx/redis/client/Request;Lio/vertx/core/Handler;)Lio/vertx/redis/client/Redis;
pop
end local 4 end local 3 6: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 7 2 onCreate Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Redis;>;
4 6 3 conn Lio/vertx/redis/client/Redis;
5 6 4 masterName Ljava/lang/String;
private void lambda$1(io.vertx.redis.client.Response);
descriptor: (Lio/vertx/redis/client/Response;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.redis.client.Response.type:()Lio/vertx/redis/client/ResponseType;
getstatic io.vertx.redis.client.ResponseType.MULTI:Lio/vertx/redis/client/ResponseType;
if_acmpne 6
1: ldc "MESSAGE"
aload 1
iconst_0
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
invokeinterface io.vertx.redis.client.Response.toString:()Ljava/lang/String;
invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
ifeq 6
2: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
ifnull 5
3: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.redis:Lio/vertx/redis/client/impl/RedisClient;
ldc "SWITCH-MASTER Received +switch-master message from Redis Sentinel."
invokestatic io.vertx.redis.client.impl.types.ErrorType.create:(Ljava/lang/String;)Lio/vertx/redis/client/impl/types/ErrorType;
invokevirtual io.vertx.redis.client.impl.RedisClient.fail:(Ljava/lang/Throwable;)V
4: goto 6
5: StackMap locals:
StackMap stack:
getstatic io.vertx.redis.client.impl.RedisSentinelClient.LOG:Lio/vertx/core/logging/Logger;
ldc "Received +switch-master message from Redis Sentinel."
invokevirtual io.vertx.core.logging.Logger.warn:(Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 7 1 msg Lio/vertx/redis/client/Response;
private void lambda$2(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: getstatic io.vertx.redis.client.impl.RedisSentinelClient.LOG:Lio/vertx/core/logging/Logger;
ldc "Unable to subscribe to Sentinel PUBSUB"
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
2: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.sentinel:Lio/vertx/redis/client/Redis;
invokeinterface io.vertx.redis.client.Redis.close:()V
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 4 1 send Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Response;>;
private void lambda$3(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: getstatic io.vertx.redis.client.impl.RedisSentinelClient.LOG:Lio/vertx/core/logging/Logger;
ldc "Unhandled exception in Sentinel PUBSUB"
aload 1
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
1: aload 0
getfield io.vertx.redis.client.impl.RedisSentinelClient.sentinel:Lio/vertx/redis/client/Redis;
invokeinterface io.vertx.redis.client.Redis.close:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/redis/client/impl/RedisSentinelClient;
0 3 1 t Ljava/lang/Throwable;
private static void lambda$12(io.vertx.core.Handler, io.vertx.core.net.SocketAddress, io.vertx.redis.client.Redis, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/net/SocketAddress;Lio/vertx/redis/client/Redis;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=4
start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 3
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 0
aload 1
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: aload 2
invokeinterface io.vertx.redis.client.Redis.close:()V
5: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 6 3 info Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Response;>;
private static void lambda$14(io.vertx.core.Handler, io.vertx.redis.client.Redis, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Lio/vertx/redis/client/Redis;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.Response
astore 3
start local 3 4: aload 0
5: aload 3
iconst_1
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
invokeinterface io.vertx.redis.client.Response.toInteger:()Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
aload 3
iconst_0
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
invokeinterface io.vertx.redis.client.Response.toString:()Ljava/lang/String;
invokestatic io.vertx.core.net.SocketAddress.inetSocketAddress:(ILjava/lang/String;)Lio/vertx/core/net/SocketAddress;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
6: invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: aload 1
invokeinterface io.vertx.redis.client.Redis.close:()V
end local 3 8: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 9 2 getMasterAddrByName Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Response;>;
4 8 3 response Lio/vertx/redis/client/Response;
private static void lambda$16(io.vertx.core.Handler, java.lang.String, io.vertx.redis.client.Redis, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/Handler;Ljava/lang/String;Lio/vertx/redis/client/Redis;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=9, args_size=4
start local 3 0: aload 3
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 3
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 3
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.redis.client.Response
astore 4
start local 4 4: aload 4
invokeinterface io.vertx.redis.client.Response.size:()I
ifne 7
5: aload 0
new java.lang.StringBuilder
dup
ldc "No slaves linked to the master: "
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;
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: goto 25
7: StackMap locals: io.vertx.redis.client.Response
StackMap stack:
aload 4
getstatic io.vertx.redis.client.impl.RedisSentinelClient.RANDOM:Ljava/util/Random;
aload 4
invokeinterface io.vertx.redis.client.Response.size:()I
invokevirtual java.util.Random.nextInt:(I)I
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
astore 5
start local 5 8: aload 5
invokeinterface io.vertx.redis.client.Response.size:()I
iconst_2
irem
ifle 11
9: aload 0
ldc "Corrupted response from the sentinel"
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
10: goto 25
11: StackMap locals: io.vertx.redis.client.Response
StackMap stack:
sipush 6379
istore 6
start local 6 12: aconst_null
astore 7
start local 7 13: iconst_0
istore 8
start local 8 14: goto 20
15: StackMap locals: int java.lang.String int
StackMap stack:
ldc "port"
aload 5
iload 8
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
invokeinterface io.vertx.redis.client.Response.toString:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 17
16: aload 5
iload 8
iconst_1
iadd
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
invokeinterface io.vertx.redis.client.Response.toInteger:()Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
istore 6
17: StackMap locals:
StackMap stack:
ldc "ip"
aload 5
iload 8
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
invokeinterface io.vertx.redis.client.Response.toString:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 19
18: aload 5
iload 8
iconst_1
iadd
invokeinterface io.vertx.redis.client.Response.get:(I)Lio/vertx/redis/client/Response;
invokeinterface io.vertx.redis.client.Response.toString:()Ljava/lang/String;
astore 7
19: StackMap locals:
StackMap stack:
iinc 8 2
StackMap locals:
StackMap stack:
20: iload 8
aload 5
invokeinterface io.vertx.redis.client.Response.size:()I
if_icmplt 15
end local 8 21: aload 7
ifnonnull 24
22: aload 0
ldc "No IP found for a SLAVE node!"
invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
23: goto 25
24: StackMap locals:
StackMap stack:
aload 0
iload 6
aload 7
invokestatic io.vertx.core.net.SocketAddress.inetSocketAddress:(ILjava/lang/String;)Lio/vertx/core/net/SocketAddress;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
end local 7 end local 6 end local 5 25: StackMap locals:
StackMap stack:
aload 2
invokeinterface io.vertx.redis.client.Redis.close:()V
end local 4 26: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 27 3 sentinelSlaves Lio/vertx/core/AsyncResult<Lio/vertx/redis/client/Response;>;
4 26 4 response Lio/vertx/redis/client/Response;
8 25 5 slaveInfoArr Lio/vertx/redis/client/Response;
12 25 6 port I
13 25 7 ip Ljava/lang/String;
14 21 8 i I
}
SourceFile: "RedisSentinelClient.java"
NestMembers:
io.vertx.redis.client.impl.RedisSentinelClient$Pair
InnerClasses:
private Pair = io.vertx.redis.client.impl.RedisSentinelClient$Pair of io.vertx.redis.client.impl.RedisSentinelClient
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles