| commit | author | age | ||
| a18bfa | 1 | Êþº¾ 3( |
| Z | 2 | D |
| 3 | | |
| 4 | | |
| 5 | | |
| 6 | | |
| 7 | | |
| 8 | ¡ ¢ £ ¤ | |
| 9 | ¥ ¦ B § ¨ | |
| 10 | © | |
| 11 | ª | |
| 12 | « | |
| 13 | ¬ ® ¯ | |
| 14 | ° ± ² ³ | |
| 15 | ° ´ µ | |
| 16 | ¥ ¶ · ¸ B ¹ º » ¼ º ½ ¾ º ¿ À Á B Â | |
| 17 | Ã Ä Å Æ B Ç | |
| 18 | È É Ê | |
| 19 | Ë Ì Í | |
| 20 | Î Ï | |
| 21 | Ð Ñ | |
| 22 | Ò Ó | |
| 23 | Ô Õ | |
| 24 | Ö × | |
| 25 | Ô Ø | |
| 26 | Ù Ú Û | |
| 27 | : Ü | |
| 28 | : Ý | |
| 29 | È Þ | |
| 30 | : ß B à á â ã | |
| 31 | ä å æ ç logger Lorg/slf4j/Logger; modelNameService 4Lcom/codingapi/tx/listener/service/ModelNameService; RuntimeVisibleAnnotations 8Lorg/springframework/beans/factory/annotation/Autowired; configReader &Lcom/codingapi/tx/config/ConfigReader; compensateService 7Lcom/codingapi/tx/compensate/service/CompensateService; managerHelper ;Lcom/codingapi/tx/netty/service/TxManagerHttpRequestHelper; <init> ()V Code LineNumberTable LocalVariableTable this <Lcom/codingapi/tx/netty/service/impl/MQTxManagerServiceImpl; createTransactionGroup (Ljava/lang/String;)V groupId Ljava/lang/String; | |
| 32 | jsonObject !Lcom/alibaba/fastjson/JSONObject; request Lcom/codingapi/tx/model/Request; addTransactionGroup Y(Ljava/lang/String;Ljava/lang/String;ZLjava/lang/String;)Lcom/codingapi/tx/model/TxGroup; taskId isGroup Z methodStr json txGroup Lcom/codingapi/tx/model/TxGroup; StackMapTable ã è é ê ¨ closeTransactionGroup (Ljava/lang/String;I)I e Ljava/lang/Exception; state I · uploadModelInfo cleanNotifyTransaction '(Ljava/lang/String;Ljava/lang/String;)I cleanNotifyTransactionHttp | |
| 33 | waitTaskId url clearRes httpGetServer ()Ljava/lang/String; sendCompensateMsg D(Ljava/lang/String;JLcom/codingapi/tx/aop/bean/TxTransactionInfo;I)V time J info -Lcom/codingapi/tx/aop/bean/TxTransactionInfo; | |
| 34 | startError modelName uniqueKey address serializers [B data className currentTime compensateInfo 2Lcom/codingapi/tx/compensate/model/CompensateInfo; <clinit> | |
| 35 | SourceFile MQTxManagerServiceImpl.java (Lorg/springframework/stereotype/Service; R S com/alibaba/fastjson/JSONObject g ë ì com/codingapi/tx/model/Request cg í R î ï ð ñ ò ó t ms s ô õ ö F G java/lang/StringBuilder #addTransactionGroupåæ°å¤çå: ÷ ø ÷ ù ê ú Z atg #addTransactionGroupåæ°å¤çå: é û ü #addTransactionGroupæç»è¿åå¼: null ý ctg þ ÿ java/lang/Exception m H I i u umi ckg L M #cleanNotifyTransactionHttp?groupId= &taskId= P Q true è | |
| 36 | getServer 0com/codingapi/tx/compensate/model/CompensateInfo R ! Z N O" #$ :com/codingapi/tx/netty/service/impl/MQTxManagerServiceImpl% &' java/lang/Object 1com/codingapi/tx/netty/service/MQTxManagerService java/lang/String com/codingapi/tx/model/TxGroup org/slf4j/Logger put 8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object; toString '(Ljava/lang/String;Ljava/lang/String;)V .com/codingapi/tx/framework/utils/SocketManager getInstance 2()Lcom/codingapi/tx/framework/utils/SocketManager; sendMsg 4(Lcom/codingapi/tx/model/Request;)Ljava/lang/String; java/lang/Integer valueOf (I)Ljava/lang/Integer; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; debug parser 4(Ljava/lang/String;)Lcom/codingapi/tx/model/TxGroup; toJsonString parseInt (Ljava/lang/String;)I 2com/codingapi/tx/listener/service/ModelNameService getModelName getIpAddress getUniqueKey $com/codingapi/tx/config/ConfigReader getTxUrl 9com/codingapi/tx/netty/service/TxManagerHttpRequestHelper httpGet &(Ljava/lang/String;)Ljava/lang/String; contains (Ljava/lang/CharSequence;)Z +com/codingapi/tx/aop/bean/TxTransactionInfo getInvocation 0()Lcom/codingapi/tx/model/TransactionInvocation; 0com/codingapi/tx/framework/utils/SerializerUtils serializeTransactionInvocation 2(Lcom/codingapi/tx/model/TransactionInvocation;)[B 1com/lorne/core/framework/utils/encode/Base64Utils encode ([B)Ljava/lang/String; ,com/codingapi/tx/model/TransactionInvocation getTargetClazz ()Ljava/lang/Class; java/lang/Class getName getMethodStr java/lang/System currentTimeMillis ()J (JLjava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;JI)V toParamsString httpPost 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; | |
| 37 | setResJson 5com/codingapi/tx/compensate/service/CompensateService saveLocal 5(Lcom/codingapi/tx/compensate/model/CompensateInfo;)V org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; ! B D E | |
| 38 | F G H I J K L M J K N O J K P Q J K | |
| 39 | R S T / *· ± U V W X Y Z T '» Y· M,+¶ W» Y,¶ · N¸ | |
| 40 | -¶ W± U , - . / & 0 V * ' W X ' [ \ ] ^ _ ` a b T ö ¾» Y· :+¶ W ,¶ W ¶ W § ¸ ¶ W² » Y· ¶ ¶ ¶ ¹ » Y¶ · :¸ | |
| 41 | ¶ :² » Y· ¶ ¶ ¶ ¹ ¸ :² » Y· ¶ Ç § ¶ ¶ ¶ ¹ ° U 2 4 5 6 7 % 8 9 9 U : e ; o < = > » ? V \ ¾ W X ¾ [ \ ¾ c \ ¾ d e ¾ f \ µ ] ^ e Y _ ` o O g \ , h i j ÿ 1 k l l l m m lÿ k l l l m m lÿ x k l l l m n l o p qÿ k l l l m n l o p q l r s T ê >» Y· N-+¶ W- ¸ ¶ W» Y -¶ · :¸ | |
| 42 | ¶ :¸ ¬:¬ 4 9 : U " E F G H * I 4 K : L < M V H < t u > W X > [ \ > v w 6 ] ^ * _ ` 4 | |
| 43 | g \ j ÿ : k l m n l x y S T ¯ O» Y· L+!*´ "¹ # ¶ W+$*´ "¹ % ¶ W+&*´ "¹ ' ¶ W» Y(+¶ · M¸ | |
| 44 | ,¶ N± U T U V ( W 8 X F Y N Z V * O W X G ] ^ F _ ` N g \ z { T ê <» Y· N-+¶ W- ,¶ W» Y)-¶ · :¸ | |
| 45 | ¶ :¸ ¬:þ¬ 1 6 7 U " ^ _ ` a ' b 1 d 7 e 9 f V H 9 t u < W X < [ \ < c \ 4 ] ^ ' _ ` 1 g \ j ÿ 7 k l l m n l x | { T ¾ H» Y· *´ *¶ +¶ ,¶ +¶ -¶ ,¶ ¶ N*´ .-¶ /:Ç ¬0¶ 1 § ¬ U m ' n 1 o 6 p 8 r V 4 H W X H [ \ H } \ ' ! ~ \ 1 \ j ý 8 l l @ T [ #» Y· *´ *¶ +¶ 2¶ ¶ L*´ .+¶ /° U | |
| 46 | x y V # W X ~ \ T £*´ "¹ # :*´ "¹ ' :*´ "¹ % :¶ 3¸ 4: ¸ 5: | |
| 47 | ¶ 3¶ 6¶ 7: ¶ 3¶ 8: ¸ 97 » :Y | |
| 48 | + · ;:*´ .» Y· *´ *¶ +¶ <¶ ¶ ¶ =¶ >:¶ ?*´ @¹ A ± U 6 ! + 2 ? I N i ¢ V £ W X £ [ \ £ £ £ w \ \ ! \ + x 2 q \ | |
| 49 | ? d \ I Z f \ N U i : g \ S T ! B¸ C³ ± U J | |
