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
isValidPublishTopicName
(String topicName)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttCodecUtil.java:44
↓ 1 callers
Method
isValide
(MulticastMessageData sendMessageData)
common/src/main/java/cn/wildfirechat/pojos/MulticastMessageData.java:47
↓ 1 callers
Method
isValide
(BroadMessageData sendMessageData)
common/src/main/java/cn/wildfirechat/pojos/BroadMessageData.java:44
↓ 1 callers
Method
isValide
()
common/src/main/java/cn/wildfirechat/pojos/InputSetGroupManager.java:46
↓ 1 callers
Method
isValide
(ReplyMessageData sendMessageData)
common/src/main/java/cn/wildfirechat/pojos/ReplyMessageData.java:45
↓ 1 callers
Method
isValidePath
(String path)
broker/src/main/java/com/xiaoleilu/loServer/handler/ActionHandler.java:105
↓ 1 callers
Method
jksDatastore
(String jksPath)
broker/src/main/java/io/moquette/server/DefaultMoquetteSslContextCreator.java:115
↓ 1 callers
Method
keepAlive
(Channel channel, int keepAlive)
broker/src/main/java/io/moquette/server/netty/NettyUtils.java:44
↓ 1 callers
Method
kickoffGroupMembers
踢出群成员 @param groupId 群组ID @param groupMemberIds 要踢出的成员用户ID列表 @param to_lines 指定线路 @param notify_message 通知消息 @return 操作结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/RobotService.java:493
↓ 1 callers
Method
kickoffGroupMembers
踢出群组成员 @param operator 操作者用户ID @param groupId 群组ID @param groupMemberIds 要踢出的成员用户ID列表 @param to_lines 消息同步到的线路列表 @param notify_message 通知消息 @return 踢出
sdk/src/main/java/cn/wildfirechat/sdk/GroupAdmin.java:270
↓ 1 callers
Method
kickoffGroupMembers
(String operator, boolean isAdmin, String groupId, List<String> memberList)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:108
↓ 1 callers
Method
kickoffPCClient
(String operator, String pcClientId)
broker/src/main/java/io/moquette/spi/ISessionsStore.java:160
↓ 1 callers
Method
kickoffUserClient
强迫用户下线 <p> 强迫用户下线后,用户需要重新获取token才能进行连接。 userId必须有效,clientId可以为空。 当clientId为空时,踢下线所有客户端;当不为空时仅踢掉对应客户端。 </p> @param userId 用户ID @param clientId 客户端ID,为空
sdk/src/main/java/cn/wildfirechat/sdk/UserAdmin.java:313
↓ 1 callers
Method
kickoffUserClient
(String userId, String clientId)
broker/src/main/java/io/moquette/spi/ISessionsStore.java:55
↓ 1 callers
Method
kickoffUserOffline
(String userId)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:105
↓ 1 callers
Method
listAll
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttProperties.java:338
↓ 1 callers
Method
listParticipants
获取会议参与者列表 @param roomId 房间ID @param advance 是否使用高级模式 @return 参与者列表 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/ConferenceAdmin.java:56
↓ 1 callers
Method
listRtpForwarders
获取RTP转发列表 @param roomId 房间ID @return RTP转发列表 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/ConferenceAdmin.java:159
↓ 1 callers
Method
listenChannel
(String operator, String channelId, boolean listen)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:232
↓ 1 callers
Method
listenChannel
(String operator, String channelId, boolean listen)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:4872
↓ 1 callers
Method
loadDefaultResource
()
broker/src/main/java/io/moquette/server/config/IResourceLoader.java:23
↓ 1 callers
Method
loadResource
(String relativePath)
broker/src/main/java/io/moquette/server/config/ClasspathResourceLoader.java:50
↓ 1 callers
Method
loadResource
(String relativePath)
broker/src/main/java/io/moquette/server/config/FileResourceLoader.java:59
↓ 1 callers
Method
loadUserSession
(String username, String clientID)
broker/src/main/java/io/moquette/spi/ISessionsStore.java:66
↓ 1 callers
Method
login
(Channel channel, MqttConnectMessage msg, final String clientId, MqttVersion mqttVersion)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:323
↓ 1 callers
Method
lookup
(int messageID)
broker/src/main/java/io/moquette/spi/ClientSession.java:67
↓ 1 callers
Method
mapChannelHandlerContext
mapChannelHandlerContext @param requestId @param ctx
broker/src/main/java/com/xiaoleilu/loServer/handler/HttpFileServerController.java:38
↓ 1 callers
Method
markAsInboundInflight
(String clientID, int messageID, StoredMessage msg)
broker/src/main/java/io/moquette/spi/ISessionsStore.java:137
↓ 1 callers
Method
maskSecret
掩码处理密钥(避免日志泄露敏感信息)
sdk/src/main/java/cn/wildfirechat/sdk/utilities/HttpUtils.java:160
↓ 1 callers
Method
mergeGroup
<code>required .Group group = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:19370
↓ 1 callers
Method
mergeGroupInfo
<code>required .GroupInfo group_info = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:5174
↓ 1 callers
Method
mergeUser
<code>required .User user = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:41038
↓ 1 callers
Method
modifyChannelInfo
(String operator, String channelId, int modifyType, String value)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:227
↓ 1 callers
Method
modifyChannelMenu
修改频道菜单 @param menus 菜单列表 @return 操作结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/ChannelServiceApi.java:111
↓ 1 callers
Method
modifyGroupInfo
修改群组信息 @param groupId 群组ID @param type 修改类型,参考ModifyGroupInfoType @param value 修改的值 @param to_lines 指定线路 @param notify_message 通知消息 @return 操作结果 @thro
sdk/src/main/java/cn/wildfirechat/sdk/RobotService.java:360
↓ 1 callers
Method
modifyGroupInfo
(String operator, String groupId, int modifyType, String value, boolean isAdmin)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:112
↓ 1 callers
Method
modifyGroupMemberExtra
(String operator, String groupId, String extra, String memberId, boolean isAdmin)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:114
↓ 1 callers
Method
modifyUserInfo
(String userId, WFCMessage.ModifyMyInfoRequest request)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:140
↓ 1 callers
Method
modifyUserStatus
(String userId, int status)
broker/src/main/java/io/moquette/spi/IMessagesStore.java:146
↓ 1 callers
Method
moveInFlightToSecondPhaseAckWaiting
(String clientID, int messageID, StoredMessage msg)
broker/src/main/java/io/moquette/spi/ISessionsStore.java:113
↓ 1 callers
Method
multicastMessage
群发消息 @param sender 发送者用户ID @param receivers 接收者ID列表 @param line 线路 @param payload 消息内容 @return 群发结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MessageAdmin.java:263
↓ 1 callers
Method
multipartUpload
multipart上传
broker/src/main/java/com/xiaoleilu/loServer/action/UploadFileAction.java:105
↓ 1 callers
Method
multipartUpload
multipart上传
broker/src/main/java/com/xiaoleilu/loServer/handler/HttpFileServerHandler.java:80
↓ 1 callers
Method
newInvalidMessage
(Throwable cause)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageFactory.java:92
↓ 1 callers
Method
newMessage
(MqttFixedHeader mqttFixedHeader, Object variableHeader, Object payload)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageFactory.java:27
↓ 1 callers
Method
nextPacketID
Return the next valid packetIdentifier for the given client session. @param clientID the clientID requesting next packet id. @return the n
broker/src/main/java/io/moquette/spi/ISessionsStore.java:100
↓ 1 callers
Method
nextPacketId
()
broker/src/main/java/io/moquette/spi/ClientSession.java:128
↓ 1 callers
Method
notRetainedPublishWithMessageId
(String topic, MqttQoS qos, ByteBuf message, int messageId)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:112
↓ 1 callers
Method
notifyChannelListenStatusChanged
(WFCMessage.ChannelInfo channelInfo, String user, boolean listen)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:844
↓ 1 callers
Method
notifyChannelWritable
(Channel channel)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:737
↓ 1 callers
Method
notifyClientConnected
(MqttConnectMessage msg)
broker/src/main/java/io/moquette/interception/Interceptor.java:35
↓ 1 callers
Method
notifyClientDisconnected
(String clientID, String username)
broker/src/main/java/io/moquette/interception/Interceptor.java:37
↓ 1 callers
Method
notifyInterceptorDisconnected
(ConnectionDescriptor descriptor, String clientID)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:651
↓ 1 callers
Method
notifyMessageAcknowledged
(InterceptAcknowledgedMessage msg)
broker/src/main/java/io/moquette/interception/Interceptor.java:41
↓ 1 callers
Method
nullableMaxUtf8Bytes
(String s)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java:714
↓ 1 callers
Method
onConnect
(InterceptConnectMessage msg)
broker/src/main/java/io/moquette/interception/InterceptHandler.java:51
↓ 1 callers
Method
onConnectionLost
(InterceptConnectionLostMessage msg)
broker/src/main/java/io/moquette/interception/InterceptHandler.java:55
↓ 1 callers
Method
onDisconnect
(InterceptDisconnectMessage msg)
broker/src/main/java/io/moquette/interception/InterceptHandler.java:53
↓ 1 callers
Method
onError
(ErrorCode errorCode)
broker/src/main/java/io/moquette/persistence/ServerAPIHelper.java:36
↓ 1 callers
Method
onMessageAcknowledged
(InterceptAcknowledgedMessage msg)
broker/src/main/java/io/moquette/interception/InterceptHandler.java:59
↓ 1 callers
Method
onResult
(byte[] response)
broker/src/main/java/com/xiaoleilu/loServer/action/Action.java:113
↓ 1 callers
Method
onRouteHandled
(byte[] ackPayload)
broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java:230
↓ 1 callers
Method
onTimeout
()
broker/src/main/java/io/moquette/persistence/ServerAPIHelper.java:37
↓ 1 callers
Method
onlyFromQos
(MqttQoS qos)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubscriptionOption.java:57
↓ 1 callers
Method
packInts
(int a, int b)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java:684
↓ 1 callers
Method
parse
(String line)
broker/src/main/java/io/moquette/spi/impl/security/AuthorizationsCollector.java:47
↓ 1 callers
Method
parse
(Reader reader)
broker/src/main/java/io/moquette/spi/impl/security/ResourceAuthenticator.java:78
↓ 1 callers
Method
parse
Parse the configuration from file.
broker/src/main/java/io/moquette/server/config/ConfigurationParser.java:45
↓ 1 callers
Method
parseAuthLine
(String line)
broker/src/main/java/io/moquette/spi/impl/security/AuthorizationsCollector.java:68
↓ 1 callers
Method
parseTopic
(String topic)
broker/src/main/java/io/moquette/spi/impl/subscriptions/Topic.java:63
↓ 1 callers
Method
payload
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubAckMessage.java:47
↓ 1 callers
Method
payload
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPublishMessage.java:40
↓ 1 callers
Method
payload
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttUnsubscribeMessage.java:48
↓ 1 callers
Method
payload
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubscribeMessage.java:48
↓ 1 callers
Method
payload2Str
(ByteBuf content)
broker/src/main/java/io/moquette/spi/impl/DebugUtils.java:23
↓ 1 callers
Method
persistFriendRequestUnreadStatus
(String userId, long readDt, long updateDt)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3566
↓ 1 callers
Method
persistMessage
(final WFCMessage.Message message, boolean update)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:766
↓ 1 callers
Method
persistSensitiveMessage
(final WFCMessage.Message message)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:848
↓ 1 callers
Method
persistSensitiveWord
(final String word)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:4542
↓ 1 callers
Method
persistUserMessage
(final String userId, final String sender, final long messageId, final long messageSeq, int type, String targ
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:1185
↓ 1 callers
Method
persistUserSetting
(final String userId, WFCMessage.UserSettingEntry entry)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:1295
↓ 1 callers
Method
pingDomain
Ping域 @param domainId 域ID @return Ping响应 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MeshAdmin.java:463
↓ 1 callers
Method
postFeeds
发布朋友圈动态 @param feedPojo 动态内容 @return 发布结果,包含消息ID @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MomentsAdmin.java:22
↓ 1 callers
Method
postMomentsFeed
发布朋友圈动态 @param type 内容类型,参考MomentsContentType @param text 文本内容 @param medias 媒体列表 @param toUsers 可见用户列表 @param excludeUsers 不可见用户列表 @param mentionedUs
sdk/src/main/java/cn/wildfirechat/sdk/RobotService.java:624
↓ 1 callers
Method
preAction
(String clientID, String fromUser, String topic, Qos1PublishHandler.IMCallback callback, ProtoConstants.Reques
broker/src/main/java/io/moquette/imhandler/IMHandler.java:176
↓ 1 callers
Method
preAction
(Request request, Response response)
broker/src/main/java/com/xiaoleilu/loServer/action/Action.java:116
↓ 1 callers
Method
processConnect
(Channel channel, MqttConnectMessage msg)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:185
↓ 1 callers
Method
processPubAck
(Channel channel, MqttPubAckMessage msg)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:501
↓ 1 callers
Method
processPubComp
(Channel channel, MqttMessage msg)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:565
↓ 1 callers
Method
processPubRec
(Channel channel, MqttMessage msg)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:561
↓ 1 callers
Method
processPubRel
Second phase of a publish QoS2 protocol, sent by publisher to the broker. Search the stored message and publish to all interested subscribers. @param
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:557
↓ 1 callers
Method
processPublish
(Channel channel, MqttPublishMessage msg)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:526
↓ 1 callers
Method
processSubscribe
(Channel channel, MqttSubscribeMessage msg)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:718
↓ 1 callers
Method
processUnsubscribe
Remove the clientID from topic subscription, if not previously subscribed, doesn't reply any error. @param channel the channel of the inco
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:714
↓ 1 callers
Method
protocolNameBytes
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttVersion.java:44
↓ 1 callers
Method
protocolVersion
(MqttVersion version)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:100
↓ 1 callers
Method
publish
(String username, String clientID, WFCMessage.Message message, ProtoConstants.RequestSourceType requestSourceT
broker/src/main/java/io/moquette/imhandler/IMHandler.java:251
↓ 1 callers
Method
publish2ChatroomReceivers
(String user, String clientId, long messageHead)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:119
↓ 1 callers
Method
publish2ChatroomReceiversDirectly
(String user, String clientId, long messageHead)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:123
↓ 1 callers
Method
publishMessage
发布跨域消息 @param messageData 消息数据 @param receivers 接收者ID列表 @param messageId 消息ID @return 发布结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MeshAdmin.java:170
← previous
next →
2,501–2,600 of 9,418, ranked by callers