Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/wildfirechat/im-server
/ functions
Functions
9,418 in github.com/wildfirechat/im-server
⨍
Functions
9,418
◇
Types & classes
953
↓ 1 callers
Method
publishRecall2ReceiversLocal
(long messageUid, String operatorId, Collection<String> receivers, String exceptClientId)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:628
↓ 1 callers
Method
publishRecallMultiCastMsg
(long messageUid, List<String> receivers)
broker/src/main/java/io/moquette/imhandler/IMHandler.java:284
↓ 1 callers
Method
publishTransparentMessage2Receivers
(long messageHead, Collection<String> receivers, int pullType, String exceptClientId)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:458
↓ 1 callers
Method
pushMessageInternel
(PushMessage pushMessage, String deviceId, String pushContent)
broker/src/main/java/cn/wildfirechat/push/PushServer.java:77
↓ 1 callers
Method
putHeadersAndCookies
填充头部信息和Cookie信息 @param headers HttpHeaders
broker/src/main/java/com/xiaoleilu/loServer/handler/Request.java:454
↓ 1 callers
Method
putIp
设置客户端IP @param ctx ChannelHandlerContext
broker/src/main/java/com/xiaoleilu/loServer/handler/Request.java:474
↓ 1 callers
Method
putParams
填充参数(GET请求的参数) @param decoder QueryStringDecoder
broker/src/main/java/com/xiaoleilu/loServer/handler/Request.java:384
↓ 1 callers
Method
queue
Return the list of persisted publishes for the given clientID. For QoS1 and QoS2 with clean session flag, this method return the list of missed publis
broker/src/main/java/io/moquette/spi/ClientSession.java:101
↓ 1 callers
Method
quitGroup
退出群组 @param groupId 群组ID @param to_lines 指定线路 @param notify_message 通知消息 @return 操作结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/RobotService.java:511
↓ 1 callers
Method
quitGroup
退出群组 @param operator 操作者用户ID @param groupId 群组ID @param to_lines 消息同步到的线路列表 @param notify_message 通知消息 @return 退出结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/GroupAdmin.java:290
↓ 1 callers
Method
quitGroup
(String operator, String groupId, boolean admin)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:109
↓ 1 callers
Method
quitGroup
(String operator, String groupId, boolean admin)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:1898
↓ 1 callers
Method
readHttpDataChunkByChunk
readHttpDataChunkByChunk
broker/src/main/java/com/xiaoleilu/loServer/action/UploadFileAction.java:155
↓ 1 callers
Method
readHttpDataChunkByChunk
readHttpDataChunkByChunk
broker/src/main/java/com/xiaoleilu/loServer/handler/HttpFileServerHandler.java:126
↓ 1 callers
Method
readResponseContent
读取响应体(兼容分块传输,修复getContentLength=-1问题)
sdk/src/main/java/cn/wildfirechat/sdk/utilities/HttpUtils.java:124
↓ 1 callers
Method
reasonCodes
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubAckPayload.java:67
↓ 1 callers
Method
recallBroadCastMessage
撤回广播消息(仅专业版支持) @param operator 操作者用户ID @param messageUid 消息UID @return 撤回结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MessageAdmin.java:180
↓ 1 callers
Method
recallCastMessage
(long messageUid, String operatorId)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:130
↓ 1 callers
Method
recallMessage
撤回消息 @param operator 操作者用户ID @param messageUid 消息UID @return 撤回结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MessageAdmin.java:89
↓ 1 callers
Method
recallMessage
撤回消息 @param messageUid 消息UID @return 操作结果,返回被撤回消息的UID @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/RobotService.java:123
↓ 1 callers
Method
recallMessage
(long messageUid, String operatorId, String clientId, boolean isAdmin, ByteBuf ackPayload)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:129
↓ 1 callers
Method
recallMultiCastMessage
撤回群发消息 @param operator 操作者用户ID @param messageUid 消息UID @param receivers 接收者ID列表 @return 撤回结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MessageAdmin.java:196
↓ 1 callers
Method
receivedPublishQos1
(Channel channel, MqttPublishMessage msg)
broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java:233
↓ 1 callers
Method
registerAllAction
()
broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java:91
↓ 1 callers
Method
registerAllAction
()
broker/src/main/java/com/xiaoleilu/loServer/LoServer.java:141
↓ 1 callers
Method
registerAllMessageContent
()
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/MessageContentFactory.java:97
↓ 1 callers
Method
reloadGroupMemberFromDB
(HazelcastInstance hzInstance, String groupId)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:586
↓ 1 callers
Method
remark
(String remark)
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/RichNotificationMessageContent.java:54
↓ 1 callers
Method
removeChannelInfo
(final String channelId)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3800
↓ 1 callers
Method
removeChatroomInfo
(String chatroomId)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:2387
↓ 1 callers
Method
removeGroupInfoFromDB
(String groupId)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3676
↓ 1 callers
Method
removeGroupMemberFromDB
(String groupId)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3702
↓ 1 callers
Method
removeSensitiveWords
(List<String> words)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:249
↓ 1 callers
Method
removeSensitives
删除敏感词 @param sensitives 敏感词列表 @return 删除结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/SensitiveAdmin.java:41
↓ 1 callers
Method
removeUserFriend
(String userId)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3447
↓ 1 callers
Method
removeUserFriendRequest
(String userId)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3470
↓ 1 callers
Method
replyMessage
回复消息 @param messageUid 原消息UID @param payload 消息内容 @param only2Sender 是否只回复给原发送者 @return 发送结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/RobotService.java:108
↓ 1 callers
Method
republishMessage
重新发布频道消息 @param messageUid 消息UID @param targets 目标用户ID列表 @return 操作结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/ChannelServiceApi.java:153
↓ 1 callers
Method
resetUnusedFields
(MqttFixedHeader mqttFixedHeader)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttCodecUtil.java:90
↓ 1 callers
Method
retainHandling
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubscriptionOption.java:83
↓ 1 callers
Method
rtpForward
RTP转发 @param roomId 房间ID @param userId 用户ID @param rtpHost RTP主机地址 @param audioPort 音频端口 @param audioPt 音频Payload类型 @param audioSSRC 音频SSRC @param vid
sdk/src/main/java/cn/wildfirechat/sdk/ConferenceAdmin.java:133
↓ 1 callers
Method
saveAddFriendRequest
(String userId, WFCMessage.AddFriendRequest request, long[] head, boolean isAdmin, boolean isRobot)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:187
↓ 1 callers
Method
saveAndBroadcast
(String username, String clientID, WFCMessage.Message message)
broker/src/main/java/io/moquette/imhandler/IMHandler.java:270
↓ 1 callers
Method
saveAndMulticast
(String username, String clientID, WFCMessage.Message message, Collection<String> targets)
broker/src/main/java/io/moquette/imhandler/IMHandler.java:277
↓ 1 callers
Method
searchChannel
(String keyword, boolean buzzy, int page)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:230
↓ 1 callers
Method
searchChannelFromDB
(String keyword, boolean buzzy, int page)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3995
↓ 1 callers
Method
searchUser
搜索用户 @param keyword 搜索关键词 @param searchType 搜索类型 @param userType 用户类型 @param page 页码 @return 搜索结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MeshAdmin.java:94
↓ 1 callers
Method
searchUser
(String userId, String keyword, int searchType, int userType, int page, List<WFCMessage.User> users)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:159
↓ 1 callers
Method
searchUserByDisplayName
(String keyword, int userType, int page, List<WFCMessage.User> nameOrIdMatched)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:421
↓ 1 callers
Method
searchUserByNameMobileUserId
(String keyword, int searchType, int userType)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:174
↓ 1 callers
Method
searchUserFromDB
(String keyword, int searchType, int userType, int page)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:547
↓ 1 callers
Method
secondPhaseAcknowledged
@param clientID the client ID accessing the second phase. @param messageID the message ID that reached the second phase. @return
broker/src/main/java/io/moquette/spi/ISessionsStore.java:122
↓ 1 callers
Method
sendAck
(ConnectionDescriptor descriptor, MqttConnectMessage msg, final String clientId)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:403
↓ 1 callers
Method
sendAndCloseFull
发送给到客户端并关闭ChannelHandlerContext @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:453
↓ 1 callers
Method
sendEmptyLast
发送结尾标记,表示发送结束 @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:492
↓ 1 callers
Method
sendFile
发送文件 @param file 文件 @return ChannelFuture @throws IOException
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:464
↓ 1 callers
Method
sendFriendRequest
发送好友请求 @param userId 用户ID @param targetId 目标用户ID @param reason 申请理由 @param force 是否强制添加(直接成为好友无需对方同意) @return 发送结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/RelationAdmin.java:142
↓ 1 callers
Method
sendFriendRequest
发送跨域好友请求 @param userId 用户ID @param targetId 目标用户ID @param reason 申请理由 @return 发送结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MeshAdmin.java:112
↓ 1 callers
Method
sendFull
发送响应到客户端 @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:439
↓ 1 callers
Method
sendMessage
发送跨域消息 @param sender 发送者用户ID @param conversation 会话信息 @param payload 消息内容 @param toUsers 接收用户ID列表 @return 发送结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MeshAdmin.java:148
↓ 1 callers
Method
sendNotModified
304 文件未修改 @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:519
↓ 1 callers
Method
sendOfflineNotify
(String clientId)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:439
↓ 1 callers
Method
setAction
增加Action类,已有的Action类将被覆盖<br> 所有Action都是以单例模式存在的! @param path 拦截路径(必须以"/"开头) @param actionClass Action类
broker/src/main/java/com/xiaoleilu/loServer/ServerSetting.java:253
↓ 1 callers
Method
setAddress
(String address)
common/src/main/java/cn/wildfirechat/pojos/InputCreateRobot.java:158
↓ 1 callers
Method
setAlias
(String alias)
common/src/main/java/cn/wildfirechat/pojos/InputUpdateAlias.java:37
↓ 1 callers
Method
setAppPage
<code>optional string app_page = 8;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:7322
↓ 1 callers
Method
setAppType
<code>required int32 appType = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:67106
↓ 1 callers
Method
setArticleId
<code>optional string article_id = 6;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:7174
↓ 1 callers
Method
setAuto
(int auto)
common/src/main/java/cn/wildfirechat/pojos/InputCreateChannel.java:108
↓ 1 callers
Method
setAutomatic
(int automatic)
common/src/main/java/cn/wildfirechat/pojos/OutputGetChannelInfo.java:112
↓ 1 callers
Method
setBeforeUid
<code>required int64 before_uid = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:63921
↓ 1 callers
Method
setBlacked
<code>optional int32 blacked = 5;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:50686
↓ 1 callers
Method
setCallback
(String callback)
common/src/main/java/cn/wildfirechat/pojos/OutputRobot.java:150
↓ 1 callers
Method
setChatroomId
(String chatroomId)
common/src/main/java/cn/wildfirechat/pojos/InputDestoryChatroom.java:22
↓ 1 callers
Method
setChatroomState
(String chatroomId, int status)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:174
↓ 1 callers
Method
setCleanSession
(boolean cleanSession)
broker/src/main/java/io/moquette/connections/MqttSession.java:46
↓ 1 callers
Method
setClientId
(String clientId)
common/src/main/java/cn/wildfirechat/pojos/OutputClient.java:37
↓ 1 callers
Method
setCode
<code>required int32 code = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:41119
↓ 1 callers
Method
setCompany
(String company)
common/src/main/java/cn/wildfirechat/pojos/InputCreateRobot.java:166
↓ 1 callers
Method
setConnectionMetrics
(MqttConnectionMetrics connectionMetrics)
broker/src/main/java/io/moquette/connections/MqttSession.java:78
↓ 1 callers
Method
setContentLength
设置响应体长度 @param contentLength 响应体长度 @return 自己
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:172
↓ 1 callers
Method
setDelay
<code>optional int64 delay = 3;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:36454
↓ 1 callers
Method
setDeleted
(int deleted)
common/src/main/java/cn/wildfirechat/pojos/InputOutputUserInfo.java:211
↓ 1 callers
Method
setDeviceId
(String deviceId)
common/src/main/java/cn/wildfirechat/pojos/InputCreateDevice.java:42
↓ 1 callers
Method
setDeviceId
(String deviceId)
common/src/main/java/cn/wildfirechat/pojos/InputDeviceId.java:18
↓ 1 callers
Method
setDisableRemoteMessageSearch
(boolean disableRemoteMessageSearch)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:52
↓ 1 callers
Method
setDisplayName
(String displayName)
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/CardMessageContent.java:69
↓ 1 callers
Method
setDomainId
(String domainId)
common/src/main/java/cn/wildfirechat/pojos/InputOutputDomainInfo.java:26
↓ 1 callers
Method
setEncryptMessage
(boolean encryptMessage)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:56
↓ 1 callers
Method
setErrorCode
(ErrorCode errorCode)
broker/src/main/java/com/xiaoleilu/loServer/RestResult.java:44
↓ 1 callers
Method
setErrorCode
<code>required int32 error_code = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:22198
↓ 1 callers
Method
setExpireDuration
<code>optional int32 expire_duration = 9;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:16991
↓ 1 callers
Method
setExpiredTime
(long expiredTime)
broker/src/main/java/io/moquette/spi/security/Tokenor.java:17
↓ 1 callers
Method
setExtra
(String extra)
common/src/main/java/cn/wildfirechat/pojos/GroupNotificationBinaryContent.java:103
↓ 1 callers
Method
setExtra
(String extra)
common/src/main/java/cn/wildfirechat/pojos/InputUpdateFriendExtra.java:37
↓ 1 callers
Method
setExtra
(String extra)
common/src/main/java/cn/wildfirechat/pojos/InputUpdateFriendStatusRequest.java:47
↓ 1 callers
Method
setExtra
(String extra)
common/src/main/java/cn/wildfirechat/pojos/InputCreateChannel.java:140
↓ 1 callers
Method
setFriendExtraRequest
(String fromUser, String targetUserId, String extra, long[] head)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:196
↓ 1 callers
Method
setFriendUid
(String friendUid)
common/src/main/java/cn/wildfirechat/pojos/InputHandleFriendRequest.java:31
↓ 1 callers
Method
setFriendUid
(String friendUid)
common/src/main/java/cn/wildfirechat/pojos/InputUpdateFriendStatusRequest.java:31
← previous
next →
2,601–2,700 of 9,418, ranked by callers