'微信登录'

admin

2020-09-05 d3ebf5b103d4deebd6ffb75f4471a6fddab8d764

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
Êþº¾4®
-b    cd
b    e    fg
b
hi
j
k
lmn
b
lopqrsrtuv
b    w
x    y
z{
z|
}p~
l    €
 b
 x
 ‚ƒ    „…    †‡ˆ
l‰
lŠ‹
secretId
Ljava/lang/String;
    secretKey

cmqManager
$Lcom/yeshi/buwan/util/mq/CMQManager;
cmqUtil
!Lcom/yeshi/buwan/util/mq/CMQUtil;
QUEUENAME_SOLR
QUEUENAME_VIDEO_UPDATE_IQIYI_2
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
getInstance
&()Lcom/yeshi/buwan/util/mq/CMQManager;
 StackMapTable
addAlbumUpdateMsg
(Ljava/lang/Long;)V
id
Ljava/lang/Long;
consumeAlbumUpdateMsg
(I)Ljava/util/List;
mm
)Lcom/yeshi/buwan/dto/mq/IqiyiAlbum2MQMsg;
msg
Lcom/qcloud/cmq/Message;
count

I
list
Ljava/util/List;
msgList
LocalVariableTypeTable
;Ljava/util/List<Lcom/yeshi/buwan/dto/mq/IqiyiAlbum2MQMsg;>;
*Ljava/util/List<Lcom/qcloud/cmq/Message;>;Œ
    Signature
>(I)Ljava/util/List<Lcom/yeshi/buwan/dto/mq/IqiyiAlbum2MQMsg;>;
deleteAlbumUpdateMsg
(Ljava/lang/String;)V
handler

addSolrMsg
consumeSolrMsg
'Lcom/yeshi/buwan/dto/mq/SolrVideoMQMsg;
9Ljava/util/List<Lcom/yeshi/buwan/dto/mq/SolrVideoMQMsg;>;
<(I)Ljava/util/List<Lcom/yeshi/buwan/dto/mq/SolrVideoMQMsg;>;
 deleteSolrMsg
<clinit>

SourceFile
CMQManager.java7812
"com/yeshi/buwan/util/mq/CMQManager346/
java/lang/StringBuilderŽ
Ž‘’“”•
java/util/ArrayList–—Œ˜™š›œ
com/qcloud/cmq/Message
'com/yeshi/buwan/dto/mq/IqiyiAlbum2MQMsgž/ŸW /¡¢£¤¥¦A§¨©ª5/
%com/yeshi/buwan/dto/mq/SolrVideoMQMsg¦W
$AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25./
 xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo0/

buwan-solr
buwan-video-update-iqiyi2=«¬­
java/lang/Object
java/util/List
java/util/Iterator
append
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
com/yeshi/buwan/util/mq/CMQUtil
sendMsg
8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;

recieveMsg
%(ILjava/lang/String;)Ljava/util/List;
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
 receiptHandle

setHandler
msgBody
java/lang/Long
    parseLong
(Ljava/lang/String;)J
valueOf
(J)Ljava/lang/Long;
setId
add
(Ljava/lang/Object;)Z
    deleteMsg
'(Ljava/lang/String;Ljava/lang/String;)Z
G(Ljava/lang/String;Ljava/lang/String;)Lcom/yeshi/buwan/util/mq/CMQUtil;
createQueue
(Ljava/lang/String;I)Z!-
./
0/
12
34    5/    6/    
78
9/

*·
±:

;
<2    =>
9=²Ç »Y·³²°:?

@A
9V²²»Y·+¶    
¶¶¶ W±:
%&;<2BC

DE9
f»Y·M²²¶N-ÆP-¹
:¹
™>¹
À:»Y·:´¶´¸¸¶,¹W§ÿ¾,°:*
*+,-5.>/H0X1a2d3;>>#FG5,HIf<2fJK
^LMSNMO^LPSNQ?þRRSúDTU
VW
9D²²+¶W±:
89;<2X/

YW
9D²²+¶ W±:
GH;<2B/

ZE9
`»Y·M²²¶N-ÆJ-¹
:¹
™8¹
À:» Y·!:´¶"´¶#,¹W§ÿÄ,°:*
KLMN5O>PHQRR[S^T;>>F[5&HI`<2`JK
XLMMNMOXL\MNQ?þRRSú>T]
^W
9D²²+¶W±:
YZ;<2X/
_8
9m9$³%&³'(³)³²%²'¸*³²²+¶,W²²+¶,W±
:"
 ,8
`a