Êþº¾ 47 chat/module/Bucket java/lang/Object itemMap Lchat/module/ConcurrentMapList; Signature $Lchat/module/ConcurrentMapList<TT;>; pullType I <init> ()V Code
|
chat/module/ConcurrentMapList
|
LineNumberTable LocalVariableTable this Lchat/module/Bucket; LocalVariableTypeTable Lchat/module/Bucket<TT;>; getInstance 8(Lchat/module/entity/ChatSpaceType;)Lchat/module/Bucket; ;(Lchat/module/entity/ChatSpaceType;)Lchat/module/Bucket<*>; ! chat/module/entity/ChatSpaceType " # Private "Lchat/module/entity/ChatSpaceType; %
|
|
' ) ( chat/module/PrivateFriendBucket * #()Lchat/module/PrivateFriendBucket; , - # Group
|
/ 1 0 chat/module/GroupBucket 2 ()Lchat/module/GroupBucket; spaceType StackMapTable sendGroupNotification (Lchat/user/User;Lcn/wildfirechat/proto/WFCMessage$CreateGroupRequest;Lcn/wildfirechat/proto/WFCMessage$MessageContent;Lchat/module/entity/Group;)V
|
8 : 9 chat/module/entity/Group ; < getId ()Ljava/lang/String;
|
> @ ? 3cn/wildfirechat/proto/WFCMessage$CreateGroupRequest A B getToLineList ()Ljava/util/List; D java/util/ArrayList
|
C
|
C G H (Ljava/util/Collection;)V J L K java/util/List M N isEmpty ()Z
|
P R Q java/lang/Integer S T valueOf (I)Ljava/lang/Integer; J V W X add (Ljava/lang/Object;)Z J Z [ \ iterator ()Ljava/util/Iterator; ^ ` _ java/util/Iterator a b next ()Ljava/lang/Object;
|
P d e f intValue ()I
|
h j i java/lang/System k l currentTimeMillis ()J
|
n p o (cn/wildfirechat/proto/WFCMessage$Message q r
|
newBuilder 4()Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
|
t v u 0cn/wildfirechat/proto/WFCMessage$Message$Builder w x
|
setContent e(Lcn/wildfirechat/proto/WFCMessage$MessageContent;)Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
|
t z { | setServerTimestamp 5(J)Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
|
t ~ getConversationBuilder 9()Lcn/wildfirechat/proto/WFCMessage$Conversation$Builder;
|
5cn/wildfirechat/proto/WFCMessage$Conversation$Builder
setType :(I)Lcn/wildfirechat/proto/WFCMessage$Conversation$Builder;
|
setTarget K(Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$Conversation$Builder;
|
setLine
|
t setConversation k(Lcn/wildfirechat/proto/WFCMessage$Conversation$Builder;)Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
|
: chat/user/User
|
t setFromUser F(Ljava/lang/String;)Lcn/wildfirechat/proto/WFCMessage$Message$Builder;
|
chat/util/MessageShardingUtil l
|
generateId
|
t | setMessageId
|
t ¢ £ ¤ build ,()Lcn/wildfirechat/proto/WFCMessage$Message;
|
¦ § ¨ pushOneMessage r(Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;Lcn/wildfirechat/proto/WFCMessage$CreateGroupRequest;)V
|
ª ¬ « java/lang/Exception printStackTrace ^ ¯ ° N hasNext user Lchat/user/User; request 5Lcn/wildfirechat/proto/WFCMessage$CreateGroupRequest; content 1Lcn/wildfirechat/proto/WFCMessage$MessageContent; group Lchat/module/entity/Group; targetId Ljava/lang/String; lines Ljava/util/List; line timestamp J builder 2Lcn/wildfirechat/proto/WFCMessage$Message$Builder; messageId e Ljava/lang/Exception; %Ljava/util/List<Ljava/lang/Integer;>; Ç java/lang/String É /cn/wildfirechat/proto/WFCMessage$MessageContent =(Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;)V
|
Exceptions
|
Í Ï Î chat/module/ModuleLoader Ð Ñ getImBusinessScheduler ()Lchat/message/MessageRunner; Ó Ô Õ run d(Lchat/module/Bucket;Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;)Ljava/lang/Runnable;
|
× Ù Ø chat/message/MessageRunner Ú Û execute (Ljava/lang/Runnable;)V message *Lcn/wildfirechat/proto/WFCMessage$Message; >(Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;Z)V à Ô á e(Lchat/module/Bucket;Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;Z)Ljava/lang/Runnable; isExceptUser Z å Ô æ (Lchat/module/Bucket;Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;Lcn/wildfirechat/proto/WFCMessage$CreateGroupRequest;)Ljava/lang/Runnable; doPushOneMessage s(Lcn/wildfirechat/proto/WFCMessage$Message;Lchat/user/User;Lcn/wildfirechat/proto/WFCMessage$CreateGroupRequest;Z)V ê java/util/LinkedHashSet
|
é
|
n í î r toBuilder
|
ð ñ ò getNotifyReceivers V(Ljava/lang/String;Lcn/wildfirechat/proto/WFCMessage$Message$Builder;Ljava/util/Set;)I
|
> ô õ ö getGroup *()Lcn/wildfirechat/proto/WFCMessage$Group;
|
ø ú ù &cn/wildfirechat/proto/WFCMessage$Group û B getMembersList
|
ý þ ÿ getGroupNotifyReceiver "(Ljava/util/List;Ljava/util/Set;)I
|
n
|
getContent 3()Lcn/wildfirechat/proto/WFCMessage$MessageContent;
|
È f getPersistFlag
|
t < getFromUser java/util/Set X remove
|
#publishTransparentMessage2Receivers D(Lcn/wildfirechat/proto/WFCMessage$Message;Ljava/util/Collection;I)V
|
getMessageContainerID Q(Lcn/wildfirechat/proto/WFCMessage$Message;)Lchat/module/entity/MessageContainer;
|
#chat/module/entity/MessageContainer getOneMember /(Ljava/lang/String;)Lchat/module/entity/Member;
|
chat/module/entity/Member ! < getSpacecode
|
# $ <
|
getSpaceid
|
&(' chat/module/entity/MessageRecord ) r(Ljava/lang/String;Ljava/lang/String;Lcn/wildfirechat/proto/WFCMessage$Message;)Lchat/module/entity/MessageRecord;
|
+ ,- addOneMessage a(ILchat/module/entity/MessageRecord;Lchat/user/User;Lcn/wildfirechat/proto/WFCMessage$Message;Z)V notifyReceivers Ljava/util/Set; messageBuilder container %Lchat/module/entity/MessageContainer; userId spaceCode spaceId record "Lchat/module/entity/MessageRecord; #Ljava/util/Set<Ljava/lang/String;>; X(Lcn/wildfirechat/proto/WFCMessage$Message;Ljava/util/Collection<Ljava/lang/String;>;I)V ; Z< java/util/Collection
|
>@? io/netty/buffer/Unpooled AB buffer ()Lio/netty/buffer/ByteBuf;
|
nD EF toByteArray ()[B
|
HJI io/netty/buffer/ByteBuf KL ensureWritable (I)Lio/netty/buffer/ByteBuf;
|
HN OP
|
writeBytes ([B)Lio/netty/buffer/ByteBuf;R MS TVU $chat/server/moquette/message/MqttQoS WX AT_MOST_ONCE &Lchat/server/moquette/message/MqttQoS;
|
Z [\ notRetainedPublish (Ljava/lang/String;Lchat/server/moquette/message/MqttQoS;Lio/netty/buffer/ByteBuf;)Lchat/server/moquette/message/MqttPublishMessage;
|
^`_ chat/user/UserStore ab getById $(Ljava/lang/String;)Lchat/user/User;
|
d ef getClient &(Ljava/lang/String;)Lchat/user/Client;
|
hji chat/user/Client kl
|
getSession ()Lchat/user/Session;
|
npo chat/user/Session qr
|
getChannel ()Lio/netty/channel/Channel; tvu io/netty/channel/Channel wx writeAndFlush 4(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture; receivers Ljava/util/Collection; payload Lio/netty/buffer/ByteBuf; byteData [B
|
publishMsg 1Lchat/server/moquette/message/MqttPublishMessage; client Lchat/user/Client; sessionC Lchat/user/Session; channel Lio/netty/channel/Channel; *Ljava/util/Collection<Ljava/lang/String;>;
|
notRetainedPublishWithMessageId
(Ljava/lang/String;Lchat/server/moquette/message/MqttQoS;Lio/netty/buffer/ByteBuf;I)Lchat/server/moquette/message/MqttPublishMessage; topic qos ,chat/server/moquette/message/MqttFixedHeader ,chat/server/moquette/message/MqttMessageType PUBLISH .Lchat/server/moquette/message/MqttMessageType;
|
Z(Lchat/server/moquette/message/MqttMessageType;ZLchat/server/moquette/message/MqttQoS;ZI)V 6chat/server/moquette/message/MqttPublishVariableHeader
|
(Ljava/lang/String;I)V /chat/server/moquette/message/MqttPublishMessage
|
¡ ¢ (Lchat/server/moquette/message/MqttFixedHeader;Lchat/server/moquette/message/MqttPublishVariableHeader;Lio/netty/buffer/ByteBuf;)V fixedHeader .Lchat/server/moquette/message/MqttFixedHeader; varHeader 8Lchat/server/moquette/message/MqttPublishVariableHeader; f(Ljava/util/List<Lcn/wildfirechat/proto/WFCMessage$GroupMember;>;Ljava/util/Set<Ljava/lang/String;>;)I© ,cn/wildfirechat/proto/WFCMessage$GroupMember
|
¨« ¬ < getMemberId V members member .Lcn/wildfirechat/proto/WFCMessage$GroupMember; @Ljava/util/List<Lcn/wildfirechat/proto/WFCMessage$GroupMember;>; j(Ljava/lang/String;Lcn/wildfirechat/proto/WFCMessage$Message$Builder;Ljava/util/Set<Ljava/lang/String;>;)I
|
t´ µ¶ getConversation 1()Lcn/wildfirechat/proto/WFCMessage$Conversation;
|
¸º¹ -cn/wildfirechat/proto/WFCMessage$Conversation » f getType
|
½ ¾¿ pase %(I)Lchat/module/entity/ChatSpaceType;
|
¸Á  < getTarget
|
/Ä õÅ .(Ljava/lang/String;)Lchat/module/entity/Group;
|
8Ç È B getMemberList
|
Ê Ë < getUserId friendGroup Lchat/module/entity/Member;
|
n´
|
Ð Ñ B getAll
|
n msgContainer messageContainer createOne ^(Ljava/lang/String;Lchat/module/entity/MessageContainer;)Lchat/module/entity/MessageContainer; (Ljava/lang/String;TT;)TT;
|
ÙÛÚ frame/object/data/DataObject Ü 2(Ljava/lang/String;)Lframe/object/data/DataObject;
|
ÙÞ ßà newEntity ()Lframe/object/data/Entity;
|
â ãä pushTo (Lframe/object/data/Entity;)V
|
Ùæ çè insertToDataBase (Lframe/object/data/Entity;)I tableName one
|
dataObject Lframe/object/data/DataObject; entity Lframe/object/data/Entity; TT; addOne :(Ljava/lang/String;Lchat/module/entity/MessageContainer;)V (Ljava/lang/String;TT;)V
|
ô Wõ '(Ljava/lang/String;Ljava/lang/Object;)V key item getOne 9(Ljava/lang/String;)Lchat/module/entity/MessageContainer; (Ljava/lang/String;)TT;
|
ü ýþ get &(Ljava/lang/String;)Ljava/lang/Object; deleteOne
|
þ delete ()Ljava/util/List<TT;>;
|
B getList size
|
f lambda$0
|
ç è lambda$1 lambda$2
|
SourceFile Bucket.java ;<T:Lchat/module/entity/MessageContainer;>Ljava/lang/Object; BootstrapMethods
|
"java/lang/invoke/LambdaMetafactory metafactory Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
|
|
Ê
|
! Þ
|
& ¨% InnerClasses+ cn/wildfirechat/proto/WFCMessage Conversation Builder CreateGroupRequest GroupMember Message MessageContent3 %java/lang/invoke/MethodHandles$Lookup5 java/lang/invoke/MethodHandles Lookup !
|
|
T *· *» Y· µ ± ) * + l ² *¦ ³ $¸ &°² +*¦ ³ $¸ .°° . / 0 2 3 4 6 3 # 4 5 6 ? ½¶ 7:,¶ =:Ç » CY· E:§ » CY· F:¹ I ¸ O¹ U W¹ Y :§ j¹ ] À P¶ c6¸ g7 ¸ m-¶ s ¶ y: ¶ }¶ ¶ ¶ ¶ W +¶ ¶ W¸ 7 ¶ W* ¶ ¡+,¶ ¥§
|
: ¶ ©¹ ® ÿ± ¨ « ª R : ; = > ? @ ) C 3 D ? G Z H _ I m J K M N O ¨ P Q ² G ¼ T z ½ ½ ± ² ½ ³ ´ ½ µ ¶ ½ · ¸ ¶ ¹ º ° » ¼ Z X ½
|
_ S ¾ ¿ m E À Á Â ¿ Ã Ä ½ ° » Å 4 t ý Æ J
|
ÿ > È 8 Æ J ^ ÿ _ > È 8 Æ J ^ t ªÿ > È 8 Æ J ^ § Ê Ë ª c ¸ Ì*+,º Ò ¶ Ö±
|
W X Ü Ý ± ² § Þ Ë ª n ¸ Ì*+, º ß ¶ Ö±
|
[ \ * Ü Ý ± ² â ã § ¨ Ë ª n ¸ Ì*+,-º ä ¶ Ö±
|
_ ` * Ü Ý ± ² ³ ´ ç è °» éY· ë:+¶ ì:6-Ç *,¶ ¶ ï6§ *-¶ ó¶ ÷¶ ü6+¶ ¶ ¶¹
|
W+¶ ¶ *+·±*+·:Ç ±,¶ : ¶¶ :
|
¶¶":
|
+¸%: ,+¶*§
|
: ¶ ©± ¥ ¨ ª ^ f g i j k $ l ' n 6 q A r N u Y v b w c z j | o } p v
¥ ª ¯ ° ° Ü Ý ° ± ² ° ³ ´ ° â ã §./ ¡0 Á
|
j F12 v :3 º .4 º
|
"5 º 67 ª Ã Ä ° §.8 4 @ þ ' tü ÿ 7 n > t Æ Æ Æ ª 9 p v,¹: :§ c¹ ] À Æ:¸=:+¶C:¾¶G¶MWQ²S¸Y:¸]¶c: ¶g:
|
|
Æ
|
¶m: Æ ¹s W¹ ® ÿ± 6 " 0 = I P U \ a k u p v v Ü Ý vyz v
|
T ± º O{| " I}~ = . I " P
|
\
v vy 4 ÿ n; ^ û _
|
[\ F *+,¸° º X Ü|
|
(»Y²+·:»Y* ·:»Y,· ° ¤ ¥ ¦ > ( º (X ( Ü| ( Â
|
£¤ ¥¦ þ ÿ § × 1>+¹ Y :§ ¹ ] À¨:,¶ª¹ W¹ ® ÿá ¬ ª « ¬ % « / ¯ 4 1 1® ¼ 1./ /
|
¯° 1 1®± 1.8 4 ÿ J ^ ñ ò ² _ |6² +,¶³¶·¸¼¦ C,¶³¶À¸Ã:¶Æ¹ Y :§ ¹ ] À :-¶É¹ W¹ ® ÿ᧠)² ,¶³¶·¸¼¦ -+¹ W-,¶³¶À¹ W¬ . ³ ´ µ ¶ : · F ¶ P ¹ S º c » k ¼ y ¿ H | |3 º |0 Á |./ y
|
1Ì ¸ : ¯Í | |.8 4 3 ÿ . Æ t 8 ^ ÿ Æ t % hM+¶Î¶· G*¶Ï¹ Y :§ ,¹ ] ÀN-+¶Ò¶Æ -+¶Î¶À¶Æ -M§ &¹ ® ÿЧ +¶Î¶· +¶Î¶À¸ÃM,° 2 Ã Å È % É 0 Ê > Ë @ Ì C È M Ï P Ð [ Ñ f Ô * h h Ü Ý fÓ2 % Ô2 h 4 ( ÿ n ^ (ÿ n ÕÖ Ë ª × +¸ØN-¶Ý:,¶á-¶åW,° Ø Ú Û Ý Þ 4 é º ê2 ëì íî êï ðñ ò h
|
*´ +,¶ó±
|
â ã
|
|
ö º
|
÷2
|
|
÷ï øù ú i +Ç °*´ +¶ûÀ° æ ç ê ö º 4 ÿù ú R *´ +¶ À° î ö º Ñ B D *´ ¶° ò f D *´ ¶¬ ö
|
Ê E *+,¶ ± W Þ E *+, ¶ ± [ ¨ E *+,-¶ ± _ "# $'() J ¸*, ¸- >*. ø* - ¨*/ n*0 t n- È*1 246
|
