IM服务端

hefeixia

2021-02-18 5b8c95c760840f09910730943b21391e47187315

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
Êþº¾4v
+chat/server/moquette/MqttIdleTimeoutHandler
%io/netty/channel/ChannelDuplexHandler
logger
Lorg/apache/log4j/Logger;
<clinit>
()V
Code
 
org/apache/log4j/Logger
    getLogger
,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;    

LineNumberTable
LocalVariableTable
<init>

this
-Lchat/server/moquette/MqttIdleTimeoutHandler;
userEventTriggered
=(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V

Exceptions
java/lang/Exception
'io/netty/handler/timeout/IdleStateEvent
!"#
state
&()Lio/netty/handler/timeout/IdleState;    %'&
"io/netty/handler/timeout/IdleState()
READER_IDLE
$Lio/netty/handler/timeout/IdleState;+-,
&io/netty/channel/ChannelHandlerContext./
channel
()Lio/netty/channel/Channel;
132
%chat/server/moquette/message/ClientID45
valueOf
C(Lio/netty/channel/Channel;)Lchat/server/moquette/message/ClientID;7
java/lang/StringBuilder9
.Firing channel inactive event. MqttClientId = 
6;<
(Ljava/lang/String;)V
6>?@
append
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
6BCD
toString
()Ljava/lang/String;
FGH
info
(Ljava/lang/Object;)V+JKL
fireChannelInactive
*()Lio/netty/channel/ChannelHandlerContext;+NOP
close
"()Lio/netty/channel/ChannelFuture;
RST
isDebugEnabled
()ZV
#Firing Netty event. MqttClientId = X
, eventClass = 
6Z?[
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
]_^
java/lang/Object`a
getClass
()Ljava/lang/Class;
ced
java/lang/ClassfD
getName
hiH
debug
k
ctx
(Lio/netty/channel/ChannelHandlerContext;
evt
Ljava/lang/Object;

e
clientId
'Lchat/server/moquette/message/ClientID;
 StackMapTable

SourceFile
MqttIdleTimeoutHandler.java!



    -
    
¸
³±


    /

*·±



    
!ˆ,Á™E,À¶ N-²$¦t+¹*
¸0:²»6Y8·:¶=¶A¶E+¹I
W+¹M
W§A²¶Q™2+¹*
¸0N²»6YU·:-¶=W¶Y,¶\¶b¶Y¶A¶g*+,·j±6 !8?FI!R"\#&‡(>ˆˆlm
ˆno7p)!%qr\%qrsûI7
tu