'初始化'

admin

2021-06-29 0a03971cf8b1ca89f171946ecce8e8e6435b9ec5

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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
Êþº¾4

@®¯    °    ±    ²³
®
´µ    ¶
    ·    ¸    ¹    º»
®
    ¼½
¾
¿
ÀÁ
ÂÃÄ
ÅÆ
®    Ç    È
    ÉF    Ê
    Ë
    Ì
    Í
ÎÏ
Í
ÎÐ
ÎÑ
ÎÒ
ÓÔ
Õ
ÎÖ
    ×
Ø
    Ù
    Ú
    Û
ÜÝ
Þ{
    ßàá
    â
    ã
Üä
Üå
Üæçèé
cmqUtil
Lorg/yeshi/utils/CMQUtil;
secretId
Ljava/lang/String;
    secretKey
endpoint
 topicEndPoint
account
Lcom/qcloud/cmq/Account;
topicAccount
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
getInstance
?(Ljava/lang/String;Ljava/lang/String;)Lorg/yeshi/utils/CMQUtil;
 StackMapTable
init
'(Ljava/lang/String;Ljava/lang/String;)V

existQueue
(Ljava/lang/String;)Z

totalCount

I

e
Ljava/lang/Exception;
    queueName
vtQueue
Ljava/util/ArrayList;
LocalVariableTypeTable
)Ljava/util/ArrayList<Ljava/lang/String;>;»½
queueNameExist

resultList
Ljava/util/List;
$Ljava/util/List<Ljava/lang/String;>;³Áê
createQueue
meta
Lcom/qcloud/cmq/QueueMeta;Æ
(Ljava/lang/String;I)Z

maxMsgSize
(Ljava/lang/String;II)Z
pollingWaitSeconds
visibilityTimeout
deleteQueue
getQueueNameList
$(Ljava/lang/String;)Ljava/util/List;
key
    Signature
8(Ljava/lang/String;)Ljava/util/List<Ljava/lang/String;>;
getQueue
*(Ljava/lang/String;)Lcom/qcloud/cmq/Queue;
queue
Lcom/qcloud/cmq/Queue;
getQueueAtrribute
.(Ljava/lang/String;)Lcom/qcloud/cmq/QueueMeta;
meta2ë
sendMsg
8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
msgId
msg

recieveMsg
,(Ljava/lang/String;)Lcom/qcloud/cmq/Message;
Lcom/qcloud/cmq/Message;
%(ILjava/lang/String;)Ljava/util/List;
count
msgList
*Ljava/util/List<Lcom/qcloud/cmq/Message;>;
?(ILjava/lang/String;)Ljava/util/List<Lcom/qcloud/cmq/Message;>;
&(ILjava/lang/String;I)Ljava/util/List;
waitSeconds
@(ILjava/lang/String;I)Ljava/util/List<Lcom/qcloud/cmq/Message;>;
    deleteMsg
'(Ljava/lang/String;Ljava/lang/String;)Z
 receiptHandle
topicNameExist
    topicName
createTopic

filterType
isAlreadySubscribe
subscriptionName
topic
Lcom/qcloud/cmq/Topic;ì

Exceptions
subscribeTopic
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Z
I(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Z

filterTags
](Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)Z
deleteSubscribeTopic
publishTopicMessage
message
7(Ljava/lang/String;Ljava/util/List;Ljava/lang/String;)Z
tagList
K(Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;Ljava/lang/String;)Z
batchPublishTopicMessage
%(Ljava/lang/String;Ljava/util/List;)Z
9(Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)Z
<clinit>

SourceFile
CMQUtil.javaKL
CDEDAB
org/yeshi/utils/CMQUtilTU
com/qcloud/cmq/AccountFDKíHIGDJI
java/util/ArrayListîï
java/lang/ExceptionðLñòóô
java/lang/StringõWêö÷cW
com/qcloud/cmq/QueueMetaqYrYoYøYjùsúyzëûüýþÿ







no messageö




    “W•

•


 ì

—‘


 BACKOFF_RETRY
JSON


U
þ




"http://cmq-queue-gz.api.qcloud.com
#https://cmq-topic-gz.api.qcloud.com
java/lang/Object
java/util/List
com/qcloud/cmq/Queue
com/qcloud/cmq/Topic
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
    listQueue
'(Ljava/lang/String;IILjava/util/List;)I
printStackTrace
size
()I
get
(I)Ljava/lang/Object;
equalsIgnoreCase
contains
(Ljava/lang/Object;)Z
msgRetentionSeconds
/(Ljava/lang/String;Lcom/qcloud/cmq/QueueMeta;)V
(Ljava/lang/String;)V
getQueueAttributes
()Lcom/qcloud/cmq/QueueMeta;
sendMessage
&(Ljava/lang/String;)Ljava/lang/String;
receiveMessage
(I)Lcom/qcloud/cmq/Message;
batchReceiveMessage
(II)Ljava/util/List;

getMessage
()Ljava/lang/String;
(Ljava/lang/CharSequence;)Z
 deleteMessage
7(Ljava/lang/String;)Lcom/qcloud/cmq/entity/CmqResponse;
    listTopic
'(Ljava/lang/String;Ljava/util/List;II)I
(Ljava/lang/String;II)V
(Ljava/lang/String;I)V
getTopic
*(Ljava/lang/String;)Lcom/qcloud/cmq/Topic;
ListSubscription
'(IILjava/lang/String;Ljava/util/List;)I
createSubscribe
K(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;Ljava/util/List;Ljava/lang/String;Ljava/lang/String;)V
deleteSubscribe
publishMessage
H(Ljava/lang/String;Ljava/util/List;Ljava/lang/String;)Ljava/lang/String;
batchPublishMessage
$(Ljava/util/List;)Ljava/util/Vector;!@
ABCDED
FD
GDHIJI
KL
MC
*·
*µ*µ±N
O
PB    QR
Me²Ç»Y·³²*+¶²°NOCDED
S

TU
M…7*+µ*,µ*»    Y²
*´*´·µ*»    Y² *´*´·µ±N+,
- .6/O 7PB7CD
7ED
VW
Mà<»Y·M*´+,¶>¬§N-¶,¶ž,¶À+¶™¬¬
N*
3567:89";8<:=O4XYZ[<PB<\D
4]^_
4]`SüaBbcW
MÆ+»Y·M*´+d,¶W§N-¶,+¹™¬¬
N"ACFDEI'J)LO*Z[+PB+\D
#de_
#dfSÿghi
b
jW
MÍ9*+·™¬»Y·M,
µ,
,µ,µ, µ!*´+,¶"¬N¬
+56N.RS
VWXY%Z+\4]6^7_O*7Z[9PB9\D
'klS
ÿ+ghm
b
jn
MØ9*+·™¬»Y·N-
µ-
,µ-µ- µ!*´+-¶"¬:¬
*45N.ef
hijk$l*n3o5p7qO47Z[9PB9\D
9oY'klS
ÿ*gh
m
b
jp
Mç=*+·™¬»Y·:µµµ µ!*´+¶"¬:¬
-89N.€
ƒ„…†&‡-‰7Š9‹;ŒO>;Z[=PB=\D
=qY=rY*klS
ÿ.gh

m
b
sW
Mk *´+¶#¬M¬
    
N“”
•–O Z[ PB \D
S
Jb
tuMË5*»    Y²
*´*´·µ»Y·M*´+d,¶>§N-¶,°
+.NœŸ+¢. /¡3£O*/Z[5PB5vD
]^_
]`Sÿ.gha
bwx
yz
Mg!*»    Y²
*´*´·µ*´+¶$M,°N¨©ªO !PB!\D
{|
}~
M­*´+¶$M
N,¶%N§
:¶-°
N¯    °²µ³´¶O4Z[PB\D
    {|lSÿgh€m
b
‚
M›*+¶&N-,¶':°N-¶
°
N¼½ ¾¿ÀÂO>
{| ƒDZ[PB\D
„DS
Pb
…†
M*+¶&M,
¶(N-°M,¶
°
NÈÉ ÊËÌÎO4    {| „‡Z[PB\D
S
Ob
…ˆMù9*,¶&N-Ç
°
:-¶):°:¶*ƶ*+¶,š¶
°
N*
ÙÛ
Üßáâãä2å7çO>Z[9PB9‰Y
9\D3{|*Še_
*Š‹S ü€ÿg
h€i
bwŒ
…MÄ*,¶&:
:¶):°:
°

Nëì
îïðòO>PB‰Y
\DŽY{|
Še_

Š‹S
ÿg
h
€i
bw
‘
M*+¶&N-,¶-W¬N-¶¬
 NøùúûüþO4{|Z[PB\D
’DS
Nb“W
MÆ+»Y·M*´+,d¶.W§N-¶,+¹™¬¬
N"
 




'
)
O*Z[+PB+”D
#de_
#dfSÿghi
b
•p
Mž*+·/™¬*´+¶0¬:¶¬

N
$
%

(
)
*
+
-O4Z[PB”D
oY–YS
Kb
•W
Mˆ*+·/™¬*´+¶1¬M,¶¬

N
7
8

;
<
=
>
@O Z[PB”D
S
Kb—‘Mµ,*´+¶2N»Y·:-d,¶3W,¹™¬¬N
L    
M
N
O(
P*
RO4,PB,”D
,˜D    #™šde_
dfS
ý*›iœ

ž
M½(*+,·4™¬§:*´+,-5¶6§
:¶¬
N&    
`    
a
d
c
f
i
g!
h&
jO4!Z[(PB(”D
(˜D(\DS Bb
Nb
ŸMà    /*+,·4™¬§:*´+,-5
78¶9§
:¶¬
#&N&    
p    
q
t
s
v#
y&
w(
x-
zO>(Z[/PB/”D
/˜D/\D/ e_
/ fS Bb
Ubw¡
¢‘
M~*´+,¶:¬N-¶¬

N
†    
‡
ˆ
‰
ŒO*Z[PB”D
˜DS
Kb
£‚
M·*´+¶2N-Ç
°-,¶;°N-¶
°N
˜    
™ 
š
›
œ

ŸO4    ™šZ[PB”D
¤DSü›ÿghh
b
£¥Mã%*´+¶2:Ǭ-,
¶<W¬:¶¬N"
¬

­
®
¯
°
±
²#
´O>
™šZ[%PB%”D
%¦e%¤D_
%¦fSü›ÿ
ghih
bw§
¨©MÏ*´+¶2N-Ǭ-,¶=W¬N-¶¬N"
Á    
 
Ã
Ä
Å
Æ
Ç
ÉO4    ™šZ[PB”D
Še_
ŠfSü›ÿghi
bwª«L
M4
>³
?³ >³
±
N
'(
¬­