Êþº¾ 4 ð
|
6
|
|
¡
|
¢ £ ¤ ¥ ¦
|
|
§ ¨
|
©
|
ª
|
« ¬
|
®
|
¯ ° ± F ²
|
³
|
´
|
µ
|
¶ ·
|
µ
|
¶ ¸
|
¶ ¹
|
¶ º
|
» ¼
|
½
|
¶ ¾
|
¿
|
À l
|
Á
|
Â
|
Ã
|
Ä Å
|
Ä Æ Ç È É cmqUtil !Lcom/yeshi/buwan/util/mq/CMQUtil; secretId Ljava/lang/String; secretKey endpoint topicEndPoint account Lcom/qcloud/cmq/Account; topicAccount <init> ()V Code LineNumberTable LocalVariableTable this getInstance G(Ljava/lang/String;Ljava/lang/String;)Lcom/yeshi/buwan/util/mq/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;>; ¦ ¨ 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; *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 createTopic topicName
|
filterType subscribeTopic 9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Z subscriptionName deleteSubscribeTopic publishTopicMessage topic Lcom/qcloud/cmq/Topic; message Ì batchPublishTopicMessage %(Ljava/lang/String;Ljava/util/List;)Z $Ljava/util/List<Ljava/lang/String;>; 9(Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)Z <clinit>
|
SourceFile CMQUtil.java A B 9 : ; : 7 8 com/yeshi/buwan/util/mq/CMQUtil J K com/qcloud/cmq/Account < : A Í > ? = : @ ? java/util/ArrayList Î Ï java/lang/Exception Ð B Ñ Ò Ó Ô java/lang/String Õ M com/qcloud/cmq/QueueMeta b O c O ` O Ö O Y × d Ø j k Ê Ù Ú Û Ü Ý Þ ß à á â
|
no message ã ä å Ø æ ç è é ê K ë ì Ì í Ü î ï "http://cmq-queue-gz.api.qcloud.com #https://cmq-topic-gz.api.qcloud.com java/lang/Object com/qcloud/cmq/Queue java/util/List 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 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; contains (Ljava/lang/CharSequence;)Z deleteMessage (Ljava/lang/String;II)V (Ljava/lang/String;I)V createSubscribe K(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V deleteSubscribe getTopic *(Ljava/lang/String;)Lcom/qcloud/cmq/Topic; publishMessage batchPublishMessage $(Ljava/util/List;)Ljava/util/Vector; ! 6
|
7 8 9 : ; :
|
< :
|
= : > ? @ ? A B C C *· *µ *µ ± D
|
E F 8 G H C e ² Ç » Y· ³ ² *+¶ ² ° D E 9 : ; : I J K C
7*+µ *,µ *» Y²
|
*´ *´ · µ *» Y² *´ *´ · µ ± D ) *
|
+ , 6 - E 7 F 8 7 9 : 7 ; : L M C à <» Y· M*´ +,¶ > ¬§ N-¶ ,¶ ,¶ À +¶ ¬¬ D *
|
1 3 4 5 8 6 7 " 9 8 : : ; E 4 N O P Q < F 8 < R : 4 S T U 4 S V I ü WB X Y M C º /» Y· M,
|
µ ,,µ , µ , µ *´ +,¶ ¬N¬ ! + , D & A B C D E ! G * H , I - J E * - P Q / F 8 / R : ' Z [ I ÿ , \ ] ^ X Y _ C Å /» Y· N-
|
µ -,µ - µ - µ *´ +-¶ ¬:¬ * + D & Q R S T U W ) X + Y - Z E 4 - P Q / F 8 / R : / ` O ' Z [ I ÿ + \ ] ^ X Y a C Ô 3» Y· : µ µ µ µ *´ +¶ ¬:¬ # . / D & j k l m n # p - q / r 1 s E > 1 P Q 3 F 8 3 R : 3 b O 3 c O * Z [ I ÿ / \ ] ^ X d M C k *´ +¶ !¬M¬
|
D z {
|
| } E P Q F 8 R : I J X e f C Ë 5*» Y²
|
*´ *´ · µ » Y· M*´ +d,¶ >§ N-¶ ,° + . D + . / 3 E * / P Q 5 F 8 5 g : S T U S V I ÿ . \ ] W X h i j k C g !*» Y²
|
*´ *´ · µ *´ +¶ "M,° D E ! F 8 ! R : l m n o C *´ +¶ "MN,¶ #N§
|
:¶ -° D E 4 P Q F 8 R : l m p [ I ÿ \ ] q ^ X r s C *+¶ $N-,¶ %:°N-¶ ° D £ ¤ ¥ ¦ § © E >
|
l m t : P Q F 8 R : u : I P X v w C *+¶ $M,
|
¶ &N-°M,¶ ° D ¯ ° ± ² ³ µ E 4 l m u x P Q F 8 R : I O X v y C ù 9*,¶ $N-Ç °:-¶ ':°:¶ (Æ ¶ ()¶ * ¶ ° D *
|
 Ä
|
Å È Ê Ë Ì Í 2 Î 7 Ð E > P Q 9 F 8 9 z O 9 R : 3 l m * { | U * { } I ü qÿ \ ] q ~ X h v C Ä *,¶ $:: ¶ ':°:°
|
D Ô Õ
|
× Ø Ù Û E > F 8 z O R : O l m
|
{ | U
|
{ } I ÿ \ ] q ~ X h C *+¶ $N-,¶ +¬N-¶ ¬ D á â ã ä å ç E 4 l m P Q F 8 R :
: I M X a C *´ + ¶ ,¬:¶ ¬ D ø
|
ù ú û ý E 4 P Q F 8 : ` O O I L X M C u *´ + ¶ -¬M,¶ ¬ D
|
|
E P Q F 8 : I L X C *´ +,-.¶ /§
|
:¶ ¬ D E 4 P Q F 8 : : R : I O X C ~ *´ +,¶ 0¬N-¶ ¬
|
D * + , - 0 E * P Q F 8 : : I K X C ½ *´ +¶ 1N-Ç ¬-,¶ 2W¬N-¶ ¬ D " < = > ? @ A B D E 4 P Q F 8 : : I ü ÿ \ ] ] X C Ï *´ +¶ 1N-Ç ¬-,¶ 3W¬N-¶ ¬ D " P Q R S T U V X E 4 P Q F 8 : { | U { I ü ÿ \ ] ~ X h B C 4 4³
|
5³ 4³
|
± D
|
% &
|
