class io.vertx.mqtt.impl.MqttServerConnection$1 extends io.netty.channel.ChannelDuplexHandler
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.mqtt.impl.MqttServerConnection$1
super_class: io.netty.channel.ChannelDuplexHandler
{
final io.vertx.mqtt.impl.MqttServerConnection this$0;
descriptor: Lio/vertx/mqtt/impl/MqttServerConnection;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(io.vertx.mqtt.impl.MqttServerConnection);
descriptor: (Lio/vertx/mqtt/impl/MqttServerConnection;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 // io.vertx.mqtt.impl.MqttServerConnection$1 this
0: .line 258
aload 0 /* this */
aload 1
putfield io.vertx.mqtt.impl.MqttServerConnection$1.this$0:Lio/vertx/mqtt/impl/MqttServerConnection;
aload 0 /* this */
invokespecial io.netty.channel.ChannelDuplexHandler.<init>:()V
return
end local 0 // io.vertx.mqtt.impl.MqttServerConnection$1 this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/mqtt/impl/MqttServerConnection$1;
MethodParameters:
Name Flags
this$0 final
public void userEventTriggered(io.netty.channel.ChannelHandlerContext, java.lang.Object);
descriptor: (Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 // io.vertx.mqtt.impl.MqttServerConnection$1 this
start local 1 // io.netty.channel.ChannelHandlerContext ctx
start local 2 // java.lang.Object evt
0: .line 263
aload 2 /* evt */
instanceof io.netty.handler.timeout.IdleStateEvent
ifeq 4
1: .line 264
aload 2 /* evt */
checkcast io.netty.handler.timeout.IdleStateEvent
astore 3 /* e */
start local 3 // io.netty.handler.timeout.IdleStateEvent e
2: .line 265
aload 3 /* e */
invokevirtual io.netty.handler.timeout.IdleStateEvent.state:()Lio/netty/handler/timeout/IdleState;
getstatic io.netty.handler.timeout.IdleState.READER_IDLE:Lio/netty/handler/timeout/IdleState;
if_acmpne 4
3: .line 266
aload 0 /* this */
getfield io.vertx.mqtt.impl.MqttServerConnection$1.this$0:Lio/vertx/mqtt/impl/MqttServerConnection;
getfield io.vertx.mqtt.impl.MqttServerConnection.endpoint:Lio/vertx/mqtt/impl/MqttEndpointImpl;
invokevirtual io.vertx.mqtt.impl.MqttEndpointImpl.close:()V
end local 3 // io.netty.handler.timeout.IdleStateEvent e
4: .line 269
StackMap locals:
StackMap stack:
return
end local 2 // java.lang.Object evt
end local 1 // io.netty.channel.ChannelHandlerContext ctx
end local 0 // io.vertx.mqtt.impl.MqttServerConnection$1 this
LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/mqtt/impl/MqttServerConnection$1;
0 5 1 ctx Lio/netty/channel/ChannelHandlerContext;
0 5 2 evt Ljava/lang/Object;
2 4 3 e Lio/netty/handler/timeout/IdleStateEvent;
Exceptions:
throws java.lang.Exception
MethodParameters:
Name Flags
ctx
evt
}
SourceFile: "MqttServerConnection.java"
EnclosingMethod: io.vertx.mqtt.impl.MqttServerConnection.handleConnect:(Lio/netty/handler/codec/mqtt/MqttConnectMessage;)V
NestHost: io.vertx.mqtt.impl.MqttServerConnection
InnerClasses:
io.vertx.mqtt.impl.MqttServerConnection$1