Êþº¾ 4(
|
` ® _ ¯ _ ° ±
|
® a
|
² ³ ´
|
µ ¶ · ¸ ¹ º » ¼ ½ ¾
|
¿ À Á
|
 u
|
Ã Ä Å
|
Æ Ç
|
È É Ê
|
® Ë Ì Í Î Ï Ð Ñ Ò Ó Ô Õ Ö × Ø
|
_ Ù Ú Û Ü
|
_ Ý Þ ß Þ à á â
|
7 Â ã
|
: ® ä
|
: å
|
: æ Þ ç è é
|
A ® ê
|
ë
|
ì í
|
ì ç
|
A î ï ð ñ
|
J ® J ò § J ó J ô õ
|
ö J ÷ ø J ù ú J û ü J ý ¡ þ ÿ queueName Ljava/lang/String; client Lcom/qcloud/cmq/CMQClient; <init> /(Ljava/lang/String;Lcom/qcloud/cmq/CMQClient;)V Code LineNumberTable LocalVariableTable this Lcom/qcloud/cmq/Queue; setQueueAttributes (Lcom/qcloud/cmq/QueueMeta;)V meta Lcom/qcloud/cmq/QueueMeta; param Ljava/util/TreeMap; result jsonObj Lcom/qcloud/cmq/Json/JSONObject; code I LocalVariableTypeTable 9Ljava/util/TreeMap<Ljava/lang/String;Ljava/lang/String;>; StackMapTable ± Á
|
Exceptions getQueueAttributes ()Lcom/qcloud/cmq/QueueMeta; sendMessage &(Ljava/lang/String;)Ljava/lang/String; msgBody '(Ljava/lang/String;I)Ljava/lang/String; delayTime batchSendMessage "(Ljava/util/List;)Ljava/util/List; vtMsgBody Ljava/util/List; $Ljava/util/List<Ljava/lang/String;>; Signature J(Ljava/util/List<Ljava/lang/String;>;)Ljava/util/List<Ljava/lang/String;>; #(Ljava/util/List;I)Ljava/util/List; k i obj vtMsgId Ljava/util/ArrayList; jsonArray Lcom/qcloud/cmq/Json/JSONArray; )Ljava/util/ArrayList<Ljava/lang/String;>; é K(Ljava/util/List<Ljava/lang/String;>;I)Ljava/util/List<Ljava/lang/String;>; receiveMessage (I)Lcom/qcloud/cmq/Message; pollingWaitSeconds msg Lcom/qcloud/cmq/Message; batchReceiveMessage (II)Ljava/util/List; numOfMsg vtMessage /Ljava/util/ArrayList<Lcom/qcloud/cmq/Message;>; .(II)Ljava/util/List<Lcom/qcloud/cmq/Message;>; deleteMessage (Ljava/lang/String;)V receiptHandle batchDeleteMessage (Ljava/util/List;)V vtReceiptHandle '(Ljava/util/List<Ljava/lang/String;>;)V
|
SourceFile
|
Queue.java e a b c d java/util/TreeMap
|
´ v maxMsgHeapNum v ¹ v visibilityTimeout » v
|
maxMsgSize ½ v msgRetentionSeconds SetQueueAttributes com/qcloud/cmq/Json/JSONObject e ¦ !com/qcloud/cmq/CMQServerException message requestId e GetQueueAttributes com/qcloud/cmq/QueueMeta
|
createTime Ë v lastModifyTime Í v activeMsgNum Ï v inactiveMsgNum Ñ v rewindMsgNum v
|
minMsgTime Õ v delayMsgNum × v
delaySeconds SendMessage msgId !com/qcloud/cmq/CMQClientException ,Error: message size is empty or more than 16 java/lang/StringBuilder msgBody. BatchSendMessage java/util/ArrayList msgList ! " #$ UserpollingWaitSeconds ReceiveMessage com/qcloud/cmq/Message Ü b § b b enqueueTime %& õ' nextVisibleTime ø' firstDequeueTime ú' dequeueCount ü v BatchReceiveMessage msgInfoList DeleteMessage receiptHandle. BatchDeleteMessage com/qcloud/cmq/Queue java/lang/Object java/lang/String java/lang/Exception com/qcloud/cmq/Json/JSONArray ()V put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; java/lang/Integer toString (I)Ljava/lang/String; com/qcloud/cmq/CMQClient call 9(Ljava/lang/String;Ljava/util/TreeMap;)Ljava/lang/String; getInt (Ljava/lang/String;)I getString ((ILjava/lang/String;Ljava/lang/String;)V rewindmsgNum java/util/List isEmpty ()Z size ()I append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ()Ljava/lang/String; get (I)Ljava/lang/Object; getJSONArray 3(Ljava/lang/String;)Lcom/qcloud/cmq/Json/JSONArray; length add (Ljava/lang/Object;)Z getLong (Ljava/lang/String;)J J ! _ ` a b c d e f g Y *· *+µ *,µ ± h i j k a b c d l m g ¸» Y· M,*´ ¶ W+´ , +´ ¸
|
¶ W+´ , +´ ¸
|
¶ W+´ ,+´ ¸
|
¶ W+´ ,+´ ¸
|
¶ W+´ ,+´ ¸
|
¶ W*´ ,¶ N» Y-· :¶ 6 » Y¶ ¶ · ¿± h J ! # % & ( ' / ( = ) D * R + Y , g - n . | 0 1 2 3 4 · 5 i > ¸ j k ¸ n o ° p q 1 r b ' s t u v w ° p x y ü ( zþ : { | } ~ g ´ Ú» Y· L+*´ ¶ W*´ +¶ M» Y,· N-¶ 6 » Y-¶ - ¶ · ¿» Y· :- ¶ µ - ¶ µ -¶ µ -¶ µ -¶ µ -!¶ µ "-#¶ µ $-%¶ µ &-'¶ µ (-)¶ µ *-+¶ µ ,--¶ µ .° h V ? A B C ' D / E 4 F J H S I ^ J i K t L M N O P « Q ¶ R Á S Ì T × W i > Ú j k Ò p q ¼ r b ' ³ s t / « u v S n o w Ò p x y ÿ J z { | } ~ g ; *+¶ /° h c i j k b } ~
g ' k» Y· N-*´ ¶ W-0+¶ W-1 ¸
|
¶ W*´ 2-¶ :» Y· :¶ 6 » Y¶ ¶ · ¿3¶ ° h *
|
f h i j & l 2 m = n F o K p c r i H k j k k b k v c p q 2 9 r b = . s t F % u v w c p x y ÿ c { z { | } ~ g M *+¶ 4° h ~ i j k w } ~ g ; ø+¹ 5 +¹ 6 ¤ » 7Y8· 9¿» Y· N-*´ ¶ W6+¹ 6 ¢ 3» :Y· ;<¶ =`¸
|
¶ =¶ >:-+¹ ? ¶ W§ÿÈ-1 ¸
|
¶ W*´ @-¶ :» Y· :¶ 6 » Y¶ ¶ · ¿» AY· B:C¶ D:6 ¶ E¢ " ¶ FÀ :
|
|
3¶ ¶ GW §ÿÚ° h V
& 1 ? Z i o z · À É Ö â ï õ i Z b 4 ; v â t
|
Ì ) v ø j k ø ø v & Ò p q r r b g s t ^ u v À 8 É / w ø & Ò p x À 8 y % ý zú :þ G { |þ ú ( } ~ g ¹ Ü» Y· M,*´ ¶ W ,Hèh¸
|
¶ W, ¸
|
¶ W§ ,Hu0¸
|
¶ W*´ I,¶ N» Y-· :¶ 6 » Y¶ ¶ · ¿» JY· K:3¶ µ LM¶ µ N0¶ µ OP¶ Qµ RS¶ Qµ TU¶ Qµ VW¶ µ X° h R © « ¬ ® & ¯ 4 ³ A ¶ L · V ¸ _ ¹ d º | ¼
½ ¾ ¿ © À µ Á Á Â Í Ã Ù Å i H Ü j k Ü v Ô p q L r b V s t _ } u v
W w Ô p x y ü 4 z þ : { | } ~ g d "» Y· N-*´ ¶ W-Y¸
|
¶ W -H èh¸
|
¶ W- ¸
|
¶ W§ -Hu0¸
|
¶ W*´ Z-¶ :» Y· :¶ 6 » Y¶ ¶ · ¿» AY· B:[¶ D:6 ¶ E¢ z ¶ FÀ :
|
» JY· K:
|
3¶ µ L
|
M¶ µ N
|
0¶ µ O
|
P¶ Qµ R
|
S¶ Qµ T
|
U¶ Qµ V
|
W¶ µ X ¶ GW §ÿ° h n Ò Ô Õ Ö " Ø 1 Ù ? Ý L ß X à c á l â q ã å ç è ¨ ê ´ ë ½ ì É í Õ î á ï í ð ù ñ ò ô è ÷ i z ´ e t
|
½ \ v " j k " ¡ v " v p q X Ê r b c ¿ s t l ¶ u v ¢ w p x ¢ £ y ü ? z þ < { |þ ú } ~ ¤ ¥ ¦ g W» Y· M,*´ ¶ W,M+¶ W*´ \,¶ N» Y-· :¶ 6 » Y¶ ¶ · ¿± h & & 0 9
|
> V i > W j k W § b O p q & 1 r b 0 ' s t 9 u v w O p x y ÿ V { z { | } ~ ¨ © g p +¹ 5 ±» Y· M,*´ ¶ W> +¹ 6 ¢ 1» :Y· ;]¶ = `¸
|
¶ =¶ >:,+ ¹ ? ¶ W§ÿË*´ ^,¶ N» Y-· :¶ 6 » Y¶ ¶ · ¿± h :
|
) C Q W" b# l$ u% z& ' i R C b 8 v j k ª p q b 1 r b l ' s t u u v w ª p x y
|
ý zú 7þ : { | } ~ « ¬
|
