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
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
Êþº¾4…
/chat/server/moquette/message/MqttPublishMessage
(chat/server/moquette/message/MqttMessage
io/netty/buffer/ByteBufHolder
<init>
‚(Lchat/server/moquette/message/MqttFixedHeader;Lchat/server/moquette/message/MqttPublishVariableHeader;Lio/netty/buffer/ByteBuf;)V
Code

U(Lchat/server/moquette/message/MqttFixedHeader;Ljava/lang/Object;Ljava/lang/Object;)V
LineNumberTable
LocalVariableTable
this
1Lchat/server/moquette/message/MqttPublishMessage;
mqttFixedHeader
.Lchat/server/moquette/message/MqttFixedHeader;
variableHeader
8Lchat/server/moquette/message/MqttPublishVariableHeader;
payload
Lio/netty/buffer/ByteBuf;
:()Lchat/server/moquette/message/MqttPublishVariableHeader;

()Ljava/lang/Object;
6chat/server/moquette/message/MqttPublishVariableHeader
()Lio/netty/buffer/ByteBuf;

 
content
"$
io/netty/buffer/ByteBuf    &('
java/lang/System)*
out
Ljava/io/PrintStream;
,.-
java/io/PrintStream/0
println
(Ljava/lang/Object;)V
#234
refCnt
()I6
,io/netty/util/IllegalReferenceCountException
589
(I)V
data
 StackMapTable
copy
3()Lchat/server/moquette/message/MqttPublishMessage;
#?<

ABC
replace
L(Lio/netty/buffer/ByteBuf;)Lchat/server/moquette/message/MqttPublishMessage;
    duplicate
#FD
retainedDuplicate
#IG

KLM
fixedHeader
0()Lchat/server/moquette/message/MqttFixedHeader;

O

Q
retain
#TR
4(I)Lchat/server/moquette/message/MqttPublishMessage;
#WRX
(I)Lio/netty/buffer/ByteBuf;
    increment

I
touch
#][
E(Ljava/lang/Object;)Lchat/server/moquette/message/MqttPublishMessage;
#`[a
-(Ljava/lang/Object;)Lio/netty/buffer/ByteBuf;
hint
Ljava/lang/Object;
release
()Z
#gde
(I)Z
#jdh
    decrement

m
!()Lio/netty/buffer/ByteBufHolder;

p<=
#(I)Lio/netty/util/ReferenceCounted;

sRU
"(I)Lio/netty/buffer/ByteBufHolder;
"()Lio/netty/util/ReferenceCounted;

wR=

yD=
:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBufHolder;
4(Ljava/lang/Object;)Lio/netty/util/ReferenceCounted;

}[^
3(Ljava/lang/Object;)Lio/netty/buffer/ByteBufHolder;

€[=

‚G=

SourceFile
MqttPublishMessage.java!



    T*+,-·
± 
 *


    2

*·À° 



    /

*¶° 


 
    (*·!À#L+Ç
²%+¶++¶1»5Y+¶1·7¿+° "#&%( :
;    ü#
<=
    6
**¶¶>¶@° 
*

D=
    6
**¶¶E¶@° 
/

G=
    6
**¶¶H¶@° 
4

BC
    E»
Y*¶J*¶N+·P° 
9 

34
    2

*¶¶1¬ 
>

R=
    8


*¶¶SW*° 
CD


RU
    C*¶¶VW*° 
I    JYZ

[=
    8


*¶¶\W*° 
OP


[^
    C*¶+¶_W*° 
U    Vbc

de
    2

*¶¶f¬ 
[

dh
    =    *¶¶i¬ 
`        kZ
A
    %

*¶l° 

A<n
    %

*¶o° 

ARq
    &*¶r° 

ARt
    &*¶r° 

ARu
    %

*¶v° 

ARn
    %

*¶v° 

A
    %

*¶N° 

ADn
    %

*¶x° 

ABz
    &*+¶@° 

A[{
    &*+¶|° 

A[~
    &*+¶|° 

A[u
    %

*¶° 

A[n
    %

*¶° 

AGn
    %

*¶° 


ƒ„