Êþº¾ 4 ¸ chat/handler/ChannelHandler chat/server/call/CallObject channelBucket Lchat/module/ChannelBucket; <clinit> ()V Code
|
chat/module/ChannelBucket getInstance ()Lchat/module/ChannelBucket; LineNumberTable LocalVariableTable <init>
|
this Lchat/handler/ChannelHandler; publishMethod create
|
addOneMethod (Ljava/lang/String;)V ! destroy # getInfo % getRoomList ' join ) leave + kickoff - pull / publish 1 2 3 dataPool Lchat/server/im/DataPool; 5 channelName
|
7 9 8 chat/server/im/DataPool : ; getString &(Ljava/lang/String;)Ljava/lang/String; = > ?
|
resultPool Lchat/server/im/ResultPool;
|
A C B chat/server/im/ResultPool D success Ljava/lang/String; G channelId
|
I J K getOne 9(Ljava/lang/String;)Lchat/module/entity/MessageContainer; M chat/module/entity/Channel O Q P "chat/module/entity/PublishOperator R S Destroy $Lchat/module/entity/PublishOperator; U V W user Lchat/user/User;
|
L Y Z [ notify 7(Lchat/module/entity/PublishOperator;Lchat/user/User;)V
|
] ^ K deleteOne channel Lchat/module/entity/Channel; StackMapTable c java/lang/String pullChannel
|
Exceptions g java/lang/Exception i 0cn/wildfirechat/proto/WFCMessage$PullChannelInfo
|
7 k l m getWFCMessage %(Ljava/lang/Class;)Ljava/lang/Object;
|
o q p ,cn/wildfirechat/proto/WFCMessage$ChannelInfo r s toByteArray ()[B
|
A u v w setBytes ([B)V request 2Lcn/wildfirechat/proto/WFCMessage$PullChannelInfo; info .Lcn/wildfirechat/proto/WFCMessage$ChannelInfo; resBytes [B
|
A add (Ljava/lang/Object;)V getChannelList
|
getAll ()Ljava/util/List;
|
channeList Ljava/util/List; LocalVariableTypeTable .Ljava/util/List<Lchat/module/entity/Channel;>; subscribe
|
L ' %(Ljava/lang/String;Lchat/user/User;)V unsubscribe
|
L ) (Lchat/user/User;)V timePoint
|
java/lang/Long parseLong (Ljava/lang/String;)J
|
L getMessageList (J)Ljava/util/List; timeStamp J messageList 4Ljava/util/List<Lchat/module/entity/MessageRecord;>;
|
7 ¤ ¥ ¦ getMessageRecord $()Lchat/module/entity/MessageRecord; O ¨ © S PublishMessage
|
L « Z ¬ Y(Lchat/module/entity/PublishOperator;Lchat/module/entity/MessageRecord;Lchat/user/User;)V record "Lchat/module/entity/MessageRecord; ° chat/module/entity/MessageRecord
|
SourceFile ChannelHandler.java InnerClasses µ cn/wildfirechat/proto/WFCMessage ChannelInfo PullChannelInfo !
|
+ ¸
|
³ ±
|
/ *· ±
7*¶ * ¶ *"¶ *$¶ *&¶ *(¶ **¶ *,¶ *.¶ ± *
|
$ * 0 6 7 N *´ 04¶ 6L*´ <¶ @± #
|
) *
|
5 E ! 5*´ 0F¶ 6L² +¶ HÀ LM,Ç ±,² N*´ T¶ X² +¶ \W*´ <¶ @± " -
|
/ 1 2 6 % 9 - < 4 = 5
|
+ G E _ ` a ý b L d e f u *´ 0h¶ jÀ hLM,¶ nN*´ <-¶ t± A D E F G * x y z { | } # h *´ 0F¶ 6L² +¶ HÀ LM*´ <,¶ ~± J
|
K M N
|
G E _ ` ^ ² ¶ L*´ <+¶ ~± Q R S $*´ 0F¶ 6L² +¶ HÀ LM,Ç ±,+*´ T¶ ± V
|
X Z [ _ # ` $
|
G E _ ` a ý b L #*´ 0F¶ 6L² +¶ HÀ LM,Ç ±,*´ T¶ ± c
|
e g h l " m #
|
G E _ ` a ý b L - Í ;*´ 0F¶ 6L*´ 0¶ 6¸ A² +¶ HÀ L:Ç ± ¶ :*´ <¶ ~± " p
|
q s # u ( v ) z 1 } : ~ 4 ;
|
1 G E $ # _ ` 1
|
¡ 1
|
¡ ¢ a þ ) b L / ® 6*´ 0F¶ 6L*´ 0¶ £M² +¶ HÀ LN-Ç ±-² §,*´ T¶ ª*´ <¶ @± "
|
! " . 5 * 6
|
, G E $ ® _ ` a þ " b ¯ L ± ² ³ o ´ ¶ h ´ ·
|
