public class io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl implements io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl
super_class: java.lang.Object
{
private static final io.vertx.core.impl.logging.Logger log;
descriptor: Lio/vertx/core/impl/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final io.vertx.core.eventbus.EventBus eb;
descriptor: Lio/vertx/core/eventbus/EventBus;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.NetServer server;
descriptor: Lio/vertx/core/net/NetServer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Map<java.lang.String, java.util.regex.Pattern> compiledREs;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Ljava/util/regex/Pattern;>;
private final io.vertx.ext.bridge.BridgeOptions options;
descriptor: Lio/vertx/ext/bridge/BridgeOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.Handler<io.vertx.ext.eventbus.bridge.tcp.BridgeEvent> bridgeEventHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/Handler<Lio/vertx/ext/eventbus/bridge/tcp/BridgeEvent;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
putstatic io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.log:Lio/vertx/core/impl/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.Vertx, io.vertx.ext.bridge.BridgeOptions, io.vertx.core.net.NetServerOptions, io.vertx.core.Handler<io.vertx.ext.eventbus.bridge.tcp.BridgeEvent>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/ext/bridge/BridgeOptions;Lio/vertx/core/net/NetServerOptions;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.compiledREs:Ljava/util/Map;
2: aload 0
aload 1
invokeinterface io.vertx.core.Vertx.eventBus:()Lio/vertx/core/eventbus/EventBus;
putfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.eb:Lio/vertx/core/eventbus/EventBus;
3: aload 0
aload 2
ifnull 4
aload 2
goto 5
StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.core.Vertx io.vertx.ext.bridge.BridgeOptions io.vertx.core.net.NetServerOptions io.vertx.core.Handler
StackMap stack: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl
4: new io.vertx.ext.bridge.BridgeOptions
dup
invokespecial io.vertx.ext.bridge.BridgeOptions.<init>:()V
StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.core.Vertx io.vertx.ext.bridge.BridgeOptions io.vertx.core.net.NetServerOptions io.vertx.core.Handler
StackMap stack: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.ext.bridge.BridgeOptions
5: putfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.options:Lio/vertx/ext/bridge/BridgeOptions;
6: aload 0
aload 4
putfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.bridgeEventHandler:Lio/vertx/core/Handler;
7: aload 0
aload 1
aload 3
ifnonnull 8
new io.vertx.core.net.NetServerOptions
dup
invokespecial io.vertx.core.net.NetServerOptions.<init>:()V
goto 9
StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.core.Vertx io.vertx.ext.bridge.BridgeOptions io.vertx.core.net.NetServerOptions io.vertx.core.Handler
StackMap stack: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.core.Vertx
8: aload 3
StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.core.Vertx io.vertx.ext.bridge.BridgeOptions io.vertx.core.net.NetServerOptions io.vertx.core.Handler
StackMap stack: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.core.Vertx io.vertx.core.net.NetServerOptions
9: invokeinterface io.vertx.core.Vertx.createNetServer:(Lio/vertx/core/net/NetServerOptions;)Lio/vertx/core/net/NetServer;
putfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
10: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
aload 0
invokedynamic handle(Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.handler(Lio/vertx/core/net/NetSocket;)V (7)
(Lio/vertx/core/net/NetSocket;)V
invokeinterface io.vertx.core.net.NetServer.connectHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetServer;
pop
11: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 12 1 vertx Lio/vertx/core/Vertx;
0 12 2 options Lio/vertx/ext/bridge/BridgeOptions;
0 12 3 netServerOptions Lio/vertx/core/net/NetServerOptions;
0 12 4 eventHandler Lio/vertx/core/Handler<Lio/vertx/ext/eventbus/bridge/tcp/BridgeEvent;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/ext/bridge/BridgeOptions;Lio/vertx/core/net/NetServerOptions;Lio/vertx/core/Handler<Lio/vertx/ext/eventbus/bridge/tcp/BridgeEvent;>;)V
MethodParameters:
Name Flags
vertx
options
netServerOptions
eventHandler
public void <init>(io.vertx.core.Vertx, io.vertx.ext.bridge.BridgeOptions, io.vertx.core.net.NetServerOptions);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/ext/bridge/BridgeOptions;Lio/vertx/core/net/NetServerOptions;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
aconst_null
invokespecial io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.<init>:(Lio/vertx/core/Vertx;Lio/vertx/ext/bridge/BridgeOptions;Lio/vertx/core/net/NetServerOptions;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 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 2 1 vertx Lio/vertx/core/Vertx;
0 2 2 options Lio/vertx/ext/bridge/BridgeOptions;
0 2 3 netServerOptions Lio/vertx/core/net/NetServerOptions;
MethodParameters:
Name Flags
vertx
options
netServerOptions
public io.vertx.core.Future<io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge> listen();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
invokeinterface io.vertx.core.net.NetServer.listen:()Lio/vertx/core/Future;
aload 0
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
Signature: ()Lio/vertx/core/Future<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;
public io.vertx.core.Future<io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge> listen(int);
descriptor: (I)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
iload 1
invokeinterface io.vertx.core.net.NetServer.listen:(I)Lio/vertx/core/Future;
aload 0
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 1 1 port I
Signature: (I)Lio/vertx/core/Future<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;
MethodParameters:
Name Flags
port
public io.vertx.core.Future<io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge> listen(int, java.lang.String);
descriptor: (ILjava/lang/String;)Lio/vertx/core/Future;
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.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
iload 1
aload 2
invokeinterface io.vertx.core.net.NetServer.listen:(ILjava/lang/String;)Lio/vertx/core/Future;
aload 0
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 1 1 port I
0 1 2 address Ljava/lang/String;
Signature: (ILjava/lang/String;)Lio/vertx/core/Future<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;
MethodParameters:
Name Flags
port
address
public io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge listen(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
aload 0
aload 1
invokedynamic handle(Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$1(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.net.NetServer.listen:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetServer;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;>;)Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;
MethodParameters:
Name Flags
handler
public io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge listen(int, java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge>>);
descriptor: (ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
iload 1
aload 2
aload 0
aload 3
invokedynamic handle(Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$2(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.net.NetServer.listen:(ILjava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/net/NetServer;
pop
1: aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 2 1 port I
0 2 2 address Ljava/lang/String;
0 2 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;>;
Signature: (ILjava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;>;)Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;
MethodParameters:
Name Flags
port
address
handler
public io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge listen(int, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge>>);
descriptor: (ILio/vertx/core/Handler;)Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
iload 1
aload 0
aload 2
invokedynamic handle(Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$3(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.net.NetServer.listen:(ILio/vertx/core/Handler;)Lio/vertx/core/net/NetServer;
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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 2 1 port I
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;>;
Signature: (ILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;>;>;)Lio/vertx/ext/eventbus/bridge/tcp/TcpEventBusBridge;
MethodParameters:
Name Flags
port
handler
private void doSendOrPub(io.vertx.core.net.NetSocket, java.lang.String, io.vertx.core.json.JsonObject, java.util.Map<java.lang.String, io.vertx.core.eventbus.MessageConsumer<?>>, java.util.Map<java.lang.String, io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject>>);
descriptor: (Lio/vertx/core/net/NetSocket;Ljava/lang/String;Lio/vertx/core/json/JsonObject;Ljava/util/Map;Ljava/util/Map;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=13, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 3
ldc "body"
invokevirtual io.vertx.core.json.JsonObject.getJsonObject:(Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
astore 6
start local 6 1: aload 3
ldc "headers"
invokevirtual io.vertx.core.json.JsonObject.getJsonObject:(Ljava/lang/String;)Lio/vertx/core/json/JsonObject;
astore 7
start local 7 2: aload 3
ldc "type"
ldc "message"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore 8
start local 8 3: aload 0
new io.vertx.core.eventbus.DeliveryOptions
dup
invokespecial io.vertx.core.eventbus.DeliveryOptions.<init>:()V
aload 7
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.parseMsgHeaders:(Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/eventbus/DeliveryOptions;
astore 9
start local 9 4: aload 8
dup
astore 10
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 5
-690213213: 5
-235365105: 6
3441010: 7
3526536: 8
836015164: 9
default: 49
}
StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl io.vertx.core.net.NetSocket java.lang.String io.vertx.core.json.JsonObject java.util.Map java.util.Map io.vertx.core.json.JsonObject io.vertx.core.json.JsonObject java.lang.String io.vertx.core.eventbus.DeliveryOptions java.lang.String
StackMap stack:
5: aload 10
ldc "register"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 32
goto 49
StackMap locals:
StackMap stack:
6: aload 10
ldc "publish"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 27
goto 49
StackMap locals:
StackMap stack:
7: aload 10
ldc "ping"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 47
goto 49
StackMap locals:
StackMap stack:
8: aload 10
ldc "send"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 49
StackMap locals:
StackMap stack:
9: aload 10
ldc "unregister"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 38
goto 49
10: StackMap locals:
StackMap stack:
aload 0
iconst_1
aload 2
aload 5
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.checkMatches:(ZLjava/lang/String;Ljava/util/Map;)Z
ifeq 25
11: aload 3
ldc "replyAddress"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 11
start local 11 12: aload 11
ifnull 15
13: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.eb:Lio/vertx/core/eventbus/EventBus;
aload 2
aload 6
aload 9
aload 2
aload 11
aload 1
aload 5
invokedynamic handle(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/net/NetSocket;Ljava/util/Map;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$4(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/net/NetSocket;Ljava/util/Map;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.eventbus.EventBus.request:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/EventBus;
pop
14: goto 23
15: StackMap locals: java.lang.String
StackMap stack:
aload 5
aload 2
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 22
16: aload 3
ldc "failureCode"
invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;)Ljava/lang/Integer;
astore 12
start local 12 17: aload 12
ifnonnull 20
18: aload 5
aload 2
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.Message
aload 6
aload 9
invokeinterface io.vertx.core.eventbus.Message.reply:(Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;)V
19: goto 23
20: StackMap locals: java.lang.Integer
StackMap stack:
aload 5
aload 2
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.Message
aload 3
ldc "failureCode"
invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;)Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
aload 3
ldc "message"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokeinterface io.vertx.core.eventbus.Message.fail:(ILjava/lang/String;)V
end local 12 21: goto 23
22: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.eb:Lio/vertx/core/eventbus/EventBus;
aload 2
aload 6
aload 9
invokeinterface io.vertx.core.eventbus.EventBus.send:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;)Lio/vertx/core/eventbus/EventBus;
pop
23: StackMap locals:
StackMap stack:
aload 5
aload 2
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 11 24: goto 50
25: StackMap locals:
StackMap stack:
ldc "access_denied"
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
26: goto 50
27: StackMap locals:
StackMap stack:
aload 0
iconst_1
aload 2
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.checkMatches:(ZLjava/lang/String;)Z
ifeq 30
28: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.eb:Lio/vertx/core/eventbus/EventBus;
aload 2
aload 6
aload 9
invokeinterface io.vertx.core.eventbus.EventBus.publish:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;)Lio/vertx/core/eventbus/EventBus;
pop
29: goto 50
30: StackMap locals:
StackMap stack:
ldc "access_denied"
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
31: goto 50
32: StackMap locals:
StackMap stack:
aload 0
iconst_0
aload 2
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.checkMatches:(ZLjava/lang/String;)Z
ifeq 36
33: aload 4
aload 2
aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.eb:Lio/vertx/core/eventbus/EventBus;
aload 2
aload 5
aload 1
invokedynamic handle(Ljava/util/Map;Lio/vertx/core/net/NetSocket;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$5(Ljava/util/Map;Lio/vertx/core/net/NetSocket;Lio/vertx/core/eventbus/Message;)V (6)
(Lio/vertx/core/eventbus/Message;)V
invokeinterface io.vertx.core.eventbus.EventBus.consumer:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/MessageConsumer;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
34: aload 0
aload 3
aload 1
invokedynamic get(Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)Ljava/util/function/Supplier;
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;
io/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$6(Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl; (6)
()Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl;
aconst_null
aconst_null
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.checkCallHook:(Ljava/util/function/Supplier;Ljava/lang/Runnable;Ljava/lang/Runnable;)V
35: goto 50
36: StackMap locals:
StackMap stack:
ldc "access_denied"
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
37: goto 50
38: StackMap locals:
StackMap stack:
aload 0
iconst_0
aload 2
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.checkMatches:(ZLjava/lang/String;)Z
ifeq 45
39: aload 4
aload 2
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageConsumer
astore 11
start local 11 40: aload 11
ifnull 43
41: aload 11
invokeinterface io.vertx.core.eventbus.MessageConsumer.unregister:()Lio/vertx/core/Future;
pop
42: goto 50
43: StackMap locals: io.vertx.core.eventbus.MessageConsumer
StackMap stack:
ldc "unknown_address"
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
end local 11 44: goto 50
45: StackMap locals:
StackMap stack:
ldc "access_denied"
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
46: goto 50
47: StackMap locals:
StackMap stack:
ldc "pong"
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
48: goto 50
49: StackMap locals:
StackMap stack:
ldc "unknown_type"
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
50: StackMap locals:
StackMap stack:
return
end local 9 end local 8 end local 7 end local 6 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 51 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 51 1 socket Lio/vertx/core/net/NetSocket;
0 51 2 address Ljava/lang/String;
0 51 3 msg Lio/vertx/core/json/JsonObject;
0 51 4 registry Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/MessageConsumer<*>;>;
0 51 5 replies Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;>;
1 51 6 body Lio/vertx/core/json/JsonObject;
2 51 7 headers Lio/vertx/core/json/JsonObject;
3 51 8 type Ljava/lang/String;
4 51 9 deliveryOptions Lio/vertx/core/eventbus/DeliveryOptions;
12 24 11 replyAddress Ljava/lang/String;
17 21 12 failureCode Ljava/lang/Integer;
40 44 11 consumer Lio/vertx/core/eventbus/MessageConsumer<*>;
Signature: (Lio/vertx/core/net/NetSocket;Ljava/lang/String;Lio/vertx/core/json/JsonObject;Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/MessageConsumer<*>;>;Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;>;)V
MethodParameters:
Name Flags
socket
address
msg
registry
replies
private void handler(io.vertx.core.net.NetSocket);
descriptor: (Lio/vertx/core/net/NetSocket;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=2
start local 0 start local 1 0: new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
astore 2
start local 2 1: new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
astore 3
start local 3 2: new io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameParser
dup
aload 0
aload 1
aload 2
aload 3
invokedynamic handle(Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;Lio/vertx/core/net/NetSocket;Ljava/util/Map;Ljava/util/Map;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$7(Lio/vertx/core/net/NetSocket;Ljava/util/Map;Ljava/util/Map;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokespecial io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameParser.<init>:(Lio/vertx/core/Handler;)V
astore 4
start local 4 3: aload 1
aload 4
invokeinterface io.vertx.core.net.NetSocket.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
4: aload 1
aload 2
aload 1
invokedynamic handle(Ljava/util/Map;Lio/vertx/core/net/NetSocket;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$11(Ljava/util/Map;Lio/vertx/core/net/NetSocket;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.net.NetSocket.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
5: aload 1
aload 2
invokedynamic handle(Ljava/util/Map;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$13(Ljava/util/Map;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.net.NetSocket.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/net/NetSocket;
pop
6: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 7 1 socket Lio/vertx/core/net/NetSocket;
1 7 2 registry Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/MessageConsumer<*>;>;
2 7 3 replies Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;>;
3 7 4 parser Lio/vertx/ext/eventbus/bridge/tcp/impl/protocol/FrameParser;
MethodParameters:
Name Flags
socket
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
aload 1
invokeinterface io.vertx.core.net.NetServer.close:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 2 1 handler 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
handler
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.server:Lio/vertx/core/net/NetServer;
invokeinterface io.vertx.core.net.NetServer.close:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
private void checkCallHook(java.util.function.Supplier<io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl>, java.lang.Runnable, java.lang.Runnable);
descriptor: (Ljava/util/function/Supplier;Ljava/lang/Runnable;Ljava/lang/Runnable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.bridgeEventHandler:Lio/vertx/core/Handler;
ifnonnull 4
1: aload 2
ifnull 7
2: aload 2
invokeinterface java.lang.Runnable.run:()V
3: goto 7
4: StackMap locals:
StackMap stack:
aload 1
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl
astore 4
start local 4 5: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.bridgeEventHandler:Lio/vertx/core/Handler;
aload 4
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: aload 4
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl.future:()Lio/vertx/core/Future;
aload 2
aload 3
invokedynamic handle(Ljava/lang/Runnable;Ljava/lang/Runnable;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$15(Ljava/lang/Runnable;Ljava/lang/Runnable;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
end local 4 7: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 8 1 eventSupplier Ljava/util/function/Supplier<Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl;>;
0 8 2 okAction Ljava/lang/Runnable;
0 8 3 rejectAction Ljava/lang/Runnable;
5 7 4 event Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl;
Signature: (Ljava/util/function/Supplier<Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl;>;Ljava/lang/Runnable;Ljava/lang/Runnable;)V
MethodParameters:
Name Flags
eventSupplier
okAction
rejectAction
private boolean checkMatches(boolean, java.lang.String);
descriptor: (ZLjava/lang/String;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
iload 1
aload 2
aconst_null
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.checkMatches:(ZLjava/lang/String;Ljava/util/Map;)Z
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 1 1 inbound Z
0 1 2 address Ljava/lang/String;
MethodParameters:
Name Flags
inbound
address
private boolean checkMatches(boolean, java.lang.String, java.util.Map<java.lang.String, io.vertx.core.eventbus.Message<io.vertx.core.json.JsonObject>>);
descriptor: (ZLjava/lang/String;Ljava/util/Map;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=10, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
ifnull 2
iload 1
ifeq 2
aload 3
aload 2
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
iload 1
ifeq 3
aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.options:Lio/vertx/ext/bridge/BridgeOptions;
invokevirtual io.vertx.ext.bridge.BridgeOptions.getInboundPermitteds:()Ljava/util/List;
goto 4
StackMap locals:
StackMap stack:
3: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.options:Lio/vertx/ext/bridge/BridgeOptions;
invokevirtual io.vertx.ext.bridge.BridgeOptions.getOutboundPermitteds:()Ljava/util/List;
StackMap locals:
StackMap stack: java.util.List
4: astore 4
start local 4 5: aload 4
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 6
goto 20
StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl int java.lang.String java.util.Map java.util.List top java.util.Iterator
StackMap stack:
6: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.ext.bridge.PermittedOptions
astore 5
start local 5 7: aload 5
invokevirtual io.vertx.ext.bridge.PermittedOptions.getAddress:()Ljava/lang/String;
astore 7
start local 7 8: aload 7
ifnonnull 11
9: aload 5
invokevirtual io.vertx.ext.bridge.PermittedOptions.getAddressRegex:()Ljava/lang/String;
astore 8
start local 8 10: goto 12
end local 8 11: StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl int java.lang.String java.util.Map java.util.List io.vertx.ext.bridge.PermittedOptions java.util.Iterator java.lang.String
StackMap stack:
aconst_null
astore 8
start local 8 12: StackMap locals: java.lang.String
StackMap stack:
aload 7
ifnonnull 17
13: aload 8
ifnull 14
aload 0
aload 8
aload 2
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.regexMatches:(Ljava/lang/String;Ljava/lang/String;)Z
ifne 14
iconst_0
goto 15
StackMap locals:
StackMap stack:
14: iconst_1
StackMap locals:
StackMap stack: int
15: istore 9
start local 9 16: goto 18
end local 9 17: StackMap locals:
StackMap stack:
aload 7
aload 2
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
istore 9
start local 9 18: StackMap locals: int
StackMap stack:
iload 9
ifeq 20
19: iconst_1
ireturn
end local 9 end local 8 end local 7 end local 5 20: StackMap locals: io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl int java.lang.String java.util.Map java.util.List top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
21: iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 22 1 inbound Z
0 22 2 address Ljava/lang/String;
0 22 3 replies Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;>;
5 22 4 matches Ljava/util/List<Lio/vertx/ext/bridge/PermittedOptions;>;
7 20 5 matchHolder Lio/vertx/ext/bridge/PermittedOptions;
8 20 7 matchAddress Ljava/lang/String;
10 11 8 matchRegex Ljava/lang/String;
12 20 8 matchRegex Ljava/lang/String;
16 17 9 addressOK Z
18 20 9 addressOK Z
Signature: (ZLjava/lang/String;Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;>;)Z
MethodParameters:
Name Flags
inbound
address
replies
private boolean regexMatches(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.compiledREs:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.regex.Pattern
astore 3
start local 3 1: aload 3
ifnonnull 4
2: aload 1
invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
astore 3
3: aload 0
getfield io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.compiledREs:Ljava/util/Map;
aload 1
aload 3
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: StackMap locals: java.util.regex.Pattern
StackMap stack:
aload 3
aload 2
invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
astore 4
start local 4 5: aload 4
invokevirtual java.util.regex.Matcher.matches:()Z
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 6 1 matchRegex Ljava/lang/String;
0 6 2 address Ljava/lang/String;
1 6 3 pattern Ljava/util/regex/Pattern;
5 6 4 m Ljava/util/regex/Matcher;
MethodParameters:
Name Flags
matchRegex
address
private io.vertx.core.eventbus.DeliveryOptions (io.vertx.core.eventbus.DeliveryOptions, io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/json/JsonObject;)Lio/vertx/core/eventbus/DeliveryOptions;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ifnonnull 2
1: aload 1
areturn
2: StackMap locals:
StackMap stack:
aload 2
invokevirtual io.vertx.core.json.JsonObject.fieldNames:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 3
start local 3 3: goto 15
4: StackMap locals: java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 4
start local 4 5: ldc "timeout"
aload 4
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 8
6: aload 1
aload 2
aload 4
invokevirtual io.vertx.core.json.JsonObject.getLong:(Ljava/lang/String;)Ljava/lang/Long;
invokevirtual java.lang.Long.longValue:()J
invokevirtual io.vertx.core.eventbus.DeliveryOptions.setSendTimeout:(J)Lio/vertx/core/eventbus/DeliveryOptions;
pop
7: goto 15
StackMap locals: java.lang.String
StackMap stack:
8: ldc "localOnly"
aload 4
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 11
9: aload 1
aload 2
aload 4
invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;)Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
invokevirtual io.vertx.core.eventbus.DeliveryOptions.setLocalOnly:(Z)Lio/vertx/core/eventbus/DeliveryOptions;
pop
10: goto 15
StackMap locals:
StackMap stack:
11: ldc "codecName"
aload 4
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 14
12: aload 1
aload 2
aload 4
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual io.vertx.core.eventbus.DeliveryOptions.setCodecName:(Ljava/lang/String;)Lio/vertx/core/eventbus/DeliveryOptions;
pop
13: goto 15
14: StackMap locals:
StackMap stack:
aload 1
aload 4
aload 2
aload 4
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual io.vertx.core.eventbus.DeliveryOptions.addHeader:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/core/eventbus/DeliveryOptions;
pop
end local 4 15: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
16: aload 1
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 17 1 options Lio/vertx/core/eventbus/DeliveryOptions;
0 17 2 headers Lio/vertx/core/json/JsonObject;
3 17 3 fnameIter Ljava/util/Iterator<Ljava/lang/String;>;
5 15 4 fname Ljava/lang/String;
MethodParameters:
Name Flags
options
headers
private static io.vertx.ext.bridge.BridgeEventType parseType(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/ext/bridge/BridgeEventType;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
dup
astore 1
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 5
-690213213: 1
-235365105: 2
3441010: 3
3526536: 4
836015164: 5
default: 11
}
StackMap locals: java.lang.String
StackMap stack:
1: aload 1
ldc "register"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 7
goto 11
StackMap locals:
StackMap stack:
2: aload 1
ldc "publish"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 9
goto 11
StackMap locals:
StackMap stack:
3: aload 1
ldc "ping"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 6
goto 11
StackMap locals:
StackMap stack:
4: aload 1
ldc "send"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
goto 11
StackMap locals:
StackMap stack:
5: aload 1
ldc "unregister"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 8
goto 11
6: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.bridge.BridgeEventType.SOCKET_PING:Lio/vertx/ext/bridge/BridgeEventType;
areturn
7: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.bridge.BridgeEventType.REGISTER:Lio/vertx/ext/bridge/BridgeEventType;
areturn
8: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.bridge.BridgeEventType.UNREGISTER:Lio/vertx/ext/bridge/BridgeEventType;
areturn
9: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.bridge.BridgeEventType.PUBLISH:Lio/vertx/ext/bridge/BridgeEventType;
areturn
10: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.bridge.BridgeEventType.SEND:Lio/vertx/ext/bridge/BridgeEventType;
areturn
11: StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "Invalid frame type "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 typeStr Ljava/lang/String;
MethodParameters:
Name Flags
typeStr
private void lambda$1(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.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 4
3: StackMap locals:
StackMap stack:
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
4: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 5 2 res Lio/vertx/core/AsyncResult<Lio/vertx/core/net/NetServer;>;
private void lambda$2(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.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 4
3: StackMap locals:
StackMap stack:
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
4: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 5 2 res Lio/vertx/core/AsyncResult<Lio/vertx/core/net/NetServer;>;
private void lambda$3(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.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 4
3: StackMap locals:
StackMap stack:
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
4: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 5 2 res Lio/vertx/core/AsyncResult<Lio/vertx/core/net/NetServer;>;
private static void lambda$4(java.lang.String, java.lang.String, io.vertx.core.net.NetSocket, java.util.Map, io.vertx.core.AsyncResult);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/net/NetSocket;Ljava/util/Map;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=9, args_size=5
start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: aload 0
aload 1
aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
checkcast io.vertx.core.eventbus.ReplyException
aload 2
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/eventbus/ReplyException;Lio/vertx/core/streams/WriteStream;)V
2: goto 12
3: StackMap locals:
StackMap stack:
aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.eventbus.Message
astore 5
start local 5 4: new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 6
start local 6 5: aload 5
invokeinterface io.vertx.core.eventbus.Message.headers:()Lio/vertx/core/MultiMap;
invokeinterface io.vertx.core.MultiMap.iterator:()Ljava/util/Iterator;
astore 8
goto 8
StackMap locals: java.lang.String java.lang.String io.vertx.core.net.NetSocket java.util.Map io.vertx.core.AsyncResult io.vertx.core.eventbus.Message io.vertx.core.json.JsonObject top java.util.Iterator
StackMap stack:
6: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 7
start local 7 7: aload 6
aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 7
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
end local 7 8: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
9: aload 5
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
ifnull 11
10: aload 3
aload 5
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
aload 5
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
11: StackMap locals: java.lang.String java.lang.String io.vertx.core.net.NetSocket java.util.Map io.vertx.core.AsyncResult io.vertx.core.eventbus.Message io.vertx.core.json.JsonObject
StackMap stack:
ldc "message"
aload 1
aload 5
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
aload 6
iconst_1
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aload 5
invokeinterface io.vertx.core.eventbus.Message.body:()Ljava/lang/Object;
checkcast io.vertx.core.json.JsonObject
aload 2
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendFrame:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;Ljava/lang/Boolean;Lio/vertx/core/json/JsonObject;Lio/vertx/core/streams/WriteStream;)V
end local 6 end local 5 12: StackMap locals:
StackMap stack:
return
end local 4 LocalVariableTable:
Start End Slot Name Signature
0 13 4 res1 Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;>;
4 12 5 response Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;
5 12 6 responseHeaders Lio/vertx/core/json/JsonObject;
7 8 7 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$5(java.util.Map, io.vertx.core.net.NetSocket, io.vertx.core.eventbus.Message);
descriptor: (Ljava/util/Map;Lio/vertx/core/net/NetSocket;Lio/vertx/core/eventbus/Message;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=6, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
ifnull 2
1: aload 0
aload 2
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
aload 2
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: StackMap locals:
StackMap stack:
new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
astore 3
start local 3 3: aload 2
invokeinterface io.vertx.core.eventbus.Message.headers:()Lio/vertx/core/MultiMap;
invokeinterface io.vertx.core.MultiMap.iterator:()Ljava/util/Iterator;
astore 5
goto 6
StackMap locals: java.util.Map io.vertx.core.net.NetSocket io.vertx.core.eventbus.Message io.vertx.core.json.JsonObject top java.util.Iterator
StackMap stack:
4: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 5: aload 3
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
pop
end local 4 6: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: ldc "message"
aload 2
invokeinterface io.vertx.core.eventbus.Message.address:()Ljava/lang/String;
aload 2
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
aload 3
aload 2
invokeinterface io.vertx.core.eventbus.Message.isSend:()Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aload 2
invokeinterface io.vertx.core.eventbus.Message.body:()Ljava/lang/Object;
checkcast io.vertx.core.json.JsonObject
aload 1
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendFrame:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/json/JsonObject;Ljava/lang/Boolean;Lio/vertx/core/json/JsonObject;Lio/vertx/core/streams/WriteStream;)V
end local 3 8: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 9 2 res1 Lio/vertx/core/eventbus/Message<Lio/vertx/core/json/JsonObject;>;
3 8 3 responseHeaders Lio/vertx/core/json/JsonObject;
5 6 4 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
private static io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl lambda$6(io.vertx.core.json.JsonObject, io.vertx.core.net.NetSocket);
descriptor: (Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
0: new io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl
dup
getstatic io.vertx.ext.bridge.BridgeEventType.REGISTERED:Lio/vertx/ext/bridge/BridgeEventType;
aload 0
aload 1
invokespecial io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl.<init>:(Lio/vertx/ext/bridge/BridgeEventType;Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)V
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$7(io.vertx.core.net.NetSocket, java.util.Map, java.util.Map, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/net/NetSocket;Ljava/util/Map;Ljava/util/Map;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=9, locals=9, args_size=5
start local 0 start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 3
1: getstatic io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.log:Lio/vertx/core/impl/logging/Logger;
aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.json.JsonObject
astore 5
start local 5 4: aload 5
ldc "type"
ldc "message"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
astore 6
start local 6 5: aload 5
ldc "address"
invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 7
start local 7 6: aload 6
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.parseType:(Ljava/lang/String;)Lio/vertx/ext/bridge/BridgeEventType;
astore 8
start local 8 7: aload 0
aload 8
aload 5
aload 1
invokedynamic get(Lio/vertx/ext/bridge/BridgeEventType;Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)Ljava/util/function/Supplier;
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;
io/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$8(Lio/vertx/ext/bridge/BridgeEventType;Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl; (6)
()Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl;
8: aload 0
aload 8
aload 7
aload 1
aload 5
aload 2
aload 3
invokedynamic run(Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;Lio/vertx/ext/bridge/BridgeEventType;Ljava/lang/String;Lio/vertx/core/net/NetSocket;Lio/vertx/core/json/JsonObject;Ljava/util/Map;Ljava/util/Map;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$9(Lio/vertx/ext/bridge/BridgeEventType;Ljava/lang/String;Lio/vertx/core/net/NetSocket;Lio/vertx/core/json/JsonObject;Ljava/util/Map;Ljava/util/Map;)V (7)
()V
9: aload 1
invokedynamic run(Lio/vertx/core/net/NetSocket;)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/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl.lambda$10(Lio/vertx/core/net/NetSocket;)V (6)
()V
10: invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.checkCallHook:(Ljava/util/function/Supplier;Ljava/lang/Runnable;Ljava/lang/Runnable;)V
end local 8 end local 7 end local 6 end local 5 11: return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
0 12 4 res Lio/vertx/core/AsyncResult<Lio/vertx/core/json/JsonObject;>;
4 11 5 msg Lio/vertx/core/json/JsonObject;
5 11 6 type Ljava/lang/String;
6 11 7 address Ljava/lang/String;
7 11 8 eventType Lio/vertx/ext/bridge/BridgeEventType;
private static void lambda$11(java.util.Map, io.vertx.core.net.NetSocket, java.lang.Throwable);
descriptor: (Ljava/util/Map;Lio/vertx/core/net/NetSocket;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: getstatic io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.log:Lio/vertx/core/impl/logging/Logger;
aload 2
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
aload 2
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
1: aload 0
invokeinterface java.util.Map.values:()Ljava/util/Collection;
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/core/eventbus/MessageConsumer.unregister()Lio/vertx/core/Future; (9 itf)
(Lio/vertx/core/eventbus/MessageConsumer;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
2: aload 0
invokeinterface java.util.Map.clear:()V
3: aload 1
invokeinterface io.vertx.core.net.NetSocket.close:()Lio/vertx/core/Future;
pop
4: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 5 2 t Ljava/lang/Throwable;
private static void lambda$13(java.util.Map, java.lang.Void);
descriptor: (Ljava/util/Map;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface java.util.Map.values:()Ljava/util/Collection;
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/core/eventbus/MessageConsumer.unregister()Lio/vertx/core/Future; (9 itf)
(Lio/vertx/core/eventbus/MessageConsumer;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
1: aload 0
invokeinterface java.util.Map.clear:()V
2: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 v Ljava/lang/Void;
private static void lambda$15(java.lang.Runnable, java.lang.Runnable, io.vertx.core.AsyncResult);
descriptor: (Ljava/lang/Runnable;Ljava/lang/Runnable;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 2
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 10
1: aload 2
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast java.lang.Boolean
invokevirtual java.lang.Boolean.booleanValue:()Z
ifeq 5
2: aload 0
ifnull 11
3: aload 0
invokeinterface java.lang.Runnable.run:()V
4: goto 11
5: StackMap locals:
StackMap stack:
aload 1
ifnull 8
6: aload 1
invokeinterface java.lang.Runnable.run:()V
7: goto 11
8: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Bridge handler prevented send or pub"
invokeinterface io.vertx.core.impl.logging.Logger.debug:(Ljava/lang/Object;)V
9: goto 11
10: StackMap locals:
StackMap stack:
getstatic io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.log:Lio/vertx/core/impl/logging/Logger;
ldc "Failure in bridge event handler"
aload 2
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
11: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 12 2 res Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;
private static io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl lambda$8(io.vertx.ext.bridge.BridgeEventType, io.vertx.core.json.JsonObject, io.vertx.core.net.NetSocket);
descriptor: (Lio/vertx/ext/bridge/BridgeEventType;Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)Lio/vertx/ext/eventbus/bridge/tcp/impl/BridgeEventImpl;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=3
0: new io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl
dup
aload 0
aload 1
aload 2
invokespecial io.vertx.ext.eventbus.bridge.tcp.impl.BridgeEventImpl.<init>:(Lio/vertx/ext/bridge/BridgeEventType;Lio/vertx/core/json/JsonObject;Lio/vertx/core/net/NetSocket;)V
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$9(io.vertx.ext.bridge.BridgeEventType, java.lang.String, io.vertx.core.net.NetSocket, io.vertx.core.json.JsonObject, java.util.Map, java.util.Map);
descriptor: (Lio/vertx/ext/bridge/BridgeEventType;Ljava/lang/String;Lio/vertx/core/net/NetSocket;Lio/vertx/core/json/JsonObject;Ljava/util/Map;Ljava/util/Map;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=7, args_size=7
start local 0 0: aload 1
getstatic io.vertx.ext.bridge.BridgeEventType.SOCKET_PING:Lio/vertx/ext/bridge/BridgeEventType;
if_acmpeq 4
aload 2
ifnonnull 4
1: ldc "missing_address"
aload 3
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
2: getstatic io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.log:Lio/vertx/core/impl/logging/Logger;
new java.lang.StringBuilder
dup
ldc "msg does not have address: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual io.vertx.core.json.JsonObject.toString:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
3: return
4: StackMap locals:
StackMap stack:
aload 0
aload 3
aload 2
aload 4
aload 5
aload 6
invokevirtual io.vertx.ext.eventbus.bridge.tcp.impl.TcpEventBusBridgeImpl.doSendOrPub:(Lio/vertx/core/net/NetSocket;Ljava/lang/String;Lio/vertx/core/json/JsonObject;Ljava/util/Map;Ljava/util/Map;)V
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/eventbus/bridge/tcp/impl/TcpEventBusBridgeImpl;
private static void lambda$10(io.vertx.core.net.NetSocket);
descriptor: (Lio/vertx/core/net/NetSocket;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
0: ldc "blocked by bridgeEvent handler"
aload 0
invokestatic io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper.sendErrFrame:(Ljava/lang/String;Lio/vertx/core/streams/WriteStream;)V
return
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "TcpEventBusBridgeImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map
TcpEventBusBridgeImpl
log: Logger
<clinit>(): void
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-tcp-eventbus-bridge: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)