MCPcopy Index your code

hub / github.com/wildfirechat/im-server / functions

Functions9,418 in github.com/wildfirechat/im-server

↓ 13 callersMethodsetOwner
(String owner)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:134
↓ 13 callersMethodsetType
<code>optional int32 type = 13;</code> <pre> 0 normal user; 1 robot </pre>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:29002
↓ 13 callersMethodwrite
(ChannelHandlerContext ctx, Object msg, ChannelPromise promise)
broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java:100
↓ 12 callersMethodgetChannelId
<code>required string channel_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:13949
↓ 12 callersMethodgetClientID
()
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:232
↓ 12 callersMethodgetImBusinessScheduler
()
broker/src/main/java/io/moquette/server/Server.java:526
↓ 12 callersMethodgetMenuFieldBuilder
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:10634
↓ 12 callersMethodgetMqttVersion
(ChannelHandlerContext ctx)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttCodecUtil.java:30
↓ 12 callersMethodgetOperator
()
common/src/main/java/cn/wildfirechat/pojos/InputGetAlias.java:24
↓ 12 callersMethodgetUsername
()
broker/src/main/java/io/moquette/server/ConnectionDescriptor.java:92
↓ 12 callersMethodhasType
<code>optional int32 type = 13;</code> <pre> 0 normal user; 1 robot </pre>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:28982
↓ 12 callersMethodisGranted
漏桶算法,https://en.wikipedia.org/wiki/Leaky_bucket
broker/src/main/java/win/liyufan/im/RateLimiter.java:38
↓ 12 callersMethodname
()
broker/src/main/java/io/moquette/spi/impl/subscriptions/Token.java:33
↓ 12 callersMethodsetDisplayName
(String displayName)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:70
↓ 12 callersMethodsetServerTimestamp
<code>optional int64 server_timestamp = 5;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26609
↓ 12 callersMethodsetTimestamp
(long timestamp)
broker/src/main/java/com/xiaoleilu/loServer/model/FriendData.java:88
↓ 12 callersMethodstrEqual
(String left, String right)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:1755
↓ 11 callersMethodbuild
()
sdk/src/main/java/ikidou/reflect/TypeBuilder.java:96
↓ 11 callersMethodcheckSendMessageResult
检查消息发送结果 <p> 验证消息是否发送成功,如果失败则退出程序。 </p> @param resultSendMessage 消息发送结果
sdk/src/main/java/cn/wildfirechat/sdk/Main.java:1463
↓ 11 callersMethodgetAddress
<code>optional string address = 7;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26928
↓ 11 callersMethodgetAppName
<code>required string app_name = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:30997
↓ 11 callersMethodgetCreateDt
<code>optional int64 create_dt = 5;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:3611
↓ 11 callersMethodgetDesc
<code>optional string desc = 6;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:8529
↓ 11 callersMethodgetFixedHeaderByte1
(MqttFixedHeader header)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java:686
↓ 11 callersMethodgetID
Returns the identifier of this intercept handler. @return
broker/src/main/java/io/moquette/interception/InterceptHandler.java:41
↓ 11 callersMethodgetMemberCount
<code>optional int32 member_count = 6;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:1548
↓ 11 callersMethodgetMobile
()
common/src/main/java/cn/wildfirechat/pojos/InputGetUserInfo.java:33
↓ 11 callersMethodgetProcessor
()
broker/src/main/java/io/moquette/server/Server.java:518
↓ 11 callersMethodgetTargetId
()
common/src/main/java/cn/wildfirechat/pojos/InputCreateChannel.java:80
↓ 11 callersMethodgetTimestamp
<code>required int64 timestamp = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:66365
↓ 11 callersMethodgetUserId
<code>required string user_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:62476
↓ 11 callersMethodprintMissConfigLog
(String config, String defaultValue)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:731
↓ 11 callersMethodqosLevel
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttFixedHeader.java:55
↓ 11 callersMethodsendApiRequest
(Response response, String topic, byte[] message, Callback callback)
broker/src/main/java/com/xiaoleilu/loServer/action/robot/RobotAction.java:109
↓ 11 callersMethodsendError
发送错误消息 @param status 错误状态码 @param msg 消息内容 @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:530
↓ 11 callersMethodsetContentType
设置Content-Type @param contentType Content-Type @return 自己
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:124
↓ 11 callersMethodsetCreateDt
(long createDt)
common/src/main/java/cn/wildfirechat/pojos/PojoGroupMember.java:76
↓ 11 callersMethodsetMobile
(String mobile)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:155
↓ 11 callersMethodsetName
(String name)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:123
↓ 11 callersMethodsetNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42615
↓ 11 callersMethodstart
(String[] args)
broker/src/main/java/io/moquette/server/Server.java:112
↓ 10 callersMethodaddToLine
<code>repeated int32 to_line = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42566
↓ 10 callersMethodclose
()
broker/src/main/java/io/moquette/server/ServerAcceptor.java:28
↓ 10 callersMethoddecode
(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java:73
↓ 10 callersMethoddecodeString
(ByteBuf buffer)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java:654
↓ 10 callersMethodensureToIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26725
↓ 10 callersMethodgetBlacked
<code>optional int32 blacked = 5;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:49798
↓ 10 callersMethodgetNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42605
↓ 10 callersMethodgetOwner
()
common/src/main/java/cn/wildfirechat/pojos/PojoGroupInfo.java:69
↓ 10 callersMethodgetParam
@param name 参数名 @return 获得请求参数
broker/src/main/java/com/xiaoleilu/loServer/handler/Request.java:198
↓ 10 callersMethodgetPhoneName
<code>optional string phone_name = 6;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:60159
↓ 10 callersMethodgetUserSessionSet
(String username)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:642
↓ 10 callersMethodhasNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42599
↓ 10 callersMethodhasUpdateDt
<code>optional int64 update_dt = 10;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:26969
↓ 10 callersMethodisAllowClientCustomGroupNotification
()
broker/src/main/java/io/moquette/spi/IMessagesStore.java:258
↓ 10 callersMethodisAllowRobotCustomGroupNotification
()
broker/src/main/java/io/moquette/spi/IMessagesStore.java:259
↓ 10 callersMethodisConnected
Determines wether a MQTT client is connected to the broker. @param clientID @return
broker/src/main/java/io/moquette/connections/IConnectionsManager.java:39
↓ 10 callersMethodmergeNotifyContent
<code>optional .MessageContent notify_content = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42645
↓ 10 callersMethodsendResponse
(Response response, ErrorCode errorCode, byte[] contents)
broker/src/main/java/com/xiaoleilu/loServer/action/IMAction.java:120
↓ 10 callersMethodsetAddress
(String address)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:102
↓ 10 callersMethodsetAlias
(String alias)
common/src/main/java/cn/wildfirechat/pojos/PojoGroupMember.java:44
↓ 10 callersMethodsetCode
(int code)
sdk/src/main/java/cn/wildfirechat/sdk/model/IMResult.java:23
↓ 10 callersMethodsetCompany
(String company)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:110
↓ 10 callersMethodsetEmail
(String email)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:94
↓ 10 callersMethodsetGender
(int gender)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:126
↓ 10 callersMethodsetHead
<code>required int64 head = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:35806
↓ 10 callersMethodsetSocial
(String social)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:30
↓ 10 callersMethodsetUpdateDt
<code>optional int64 update_dt = 10;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:28850
↓ 10 callersMethodsetUserId
(String userId)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:115
↓ 10 callersMethodsha1Hex
(String input)
VerifyAdminSecretTool.java:105
↓ 9 callersMethodAESDecrypt
(byte[] sSrc, String userKey, boolean checkTime)
broker/src/main/java/io/moquette/spi/impl/security/AES.java:114
↓ 9 callersMethodaddListener
<code>repeated string listener = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:13884
↓ 9 callersMethodconnAck
(MqttConnectReturnCode returnCode)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:299
↓ 9 callersMethodensureAddedMemberIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:18157
↓ 9 callersMethodensureChannelIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:15037
↓ 9 callersMethodensureInfoIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:37786
↓ 9 callersMethodensureMemberIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:39040
↓ 9 callersMethodensureMessageIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:37034
↓ 9 callersMethodensureRequestIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:40286
↓ 9 callersMethodensureResultIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:41584
↓ 9 callersMethodensureSubMenuIsMutable
()
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:7358
↓ 9 callersMethodgenerateId
ID = timestamp(43) + nodeId(6) + rotateId(15) 所以时间限制是到2157/5/15(2的42次幂代表的时间 + (2018-1970))。节点数限制是小于64,每台服务器每毫秒最多发送32768条消息 @return
broker/src/main/java/win/liyufan/im/MessageShardingUtil.java:38
↓ 9 callersMethodgetDeviceToken
<code>required string device_token = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:31012
↓ 9 callersMethodgetJoinType
<code>optional int32 join_type = 11;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:1603
↓ 9 callersMethodgetMessageTable
(long mid)
broker/src/main/java/win/liyufan/im/MessageShardingUtil.java:85
↓ 9 callersMethodgetMute
<code>optional int32 mute = 10;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:1593
↓ 9 callersMethodgetName
()
common/src/main/java/cn/wildfirechat/pojos/InputGetUserInfo.java:49
↓ 9 callersMethodgetPushType
<code>optional int32 push_type = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:60119
↓ 9 callersMethodgetRemoteMediaUrl
<code>optional string remoteMediaUrl = 7;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:15445
↓ 9 callersMethodgetTimestamp
()
broker/src/main/java/com/xiaoleilu/loServer/model/FriendData.java:84
↓ 9 callersMethodgetUserId
()
common/src/main/java/cn/wildfirechat/pojos/InputUserId.java:21
↓ 9 callersMethodgetUserStatus
(String userId)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:147
↓ 9 callersMethodgetVariableLengthInt
(int num)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java:746
↓ 9 callersMethodhasGroupId
<code>required string group_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:41839
↓ 9 callersMethodhasGroupId
<code>required string group_id = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:42457
↓ 9 callersMethodmessagesStore
Factory method to instantiate the messages store. @return the create instance of IMessagesStore.
broker/src/main/java/io/moquette/spi/IStore.java:30
↓ 9 callersMethodpersistOrUpdateFriendData
(final FriendData request)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3637
↓ 9 callersMethodsessionForUser
(String username)
broker/src/main/java/io/moquette/spi/ISessionsStore.java:68
↓ 9 callersMethodsetDeleted
(int deleted)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:72
↓ 9 callersMethodsetDisplayName
(String displayName)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:139
← previousnext →201–300 of 9,418, ranked by callers