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
Method
payload
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttUnsubAckMessage.java:58
Method
payload
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnectMessage.java:36
Method
payload
(ByteBuf payload)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:56
Method
persistChannelListener
(final String groupId, final List<String> memberList)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:3920
Method
preAction
(Request request, Response response)
broker/src/main/java/com/xiaoleilu/loServer/action/channel/ChannelAction.java:42
Method
preAction
(Request request, Response response)
broker/src/main/java/com/xiaoleilu/loServer/action/robot/RobotAction.java:44
Method
preAction
(Request request, Response response)
broker/src/main/java/com/xiaoleilu/loServer/action/admin/AdminAction.java:49
Method
properties
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageIdAndPropertiesVariableHeader.java:36
Method
properties
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnAckVariableHeader.java:51
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:66
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:190
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:242
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:285
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:324
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:547
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:583
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:638
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:672
Method
properties
(MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:700
Method
properties
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnectVariableHeader.java:118
Method
propertyId
Get MQTT property ID @return property ID
broker/src/main/java/io/netty/handler/codec/mqtt/MqttProperties.java:139
Method
pubAck
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:740
Method
publish
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:728
Method
publishRecall2Receivers
(long messageUid, String operatorId, Set<String> receivers, String exceptClientId)
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:664
Method
publishRetained
(ClientSession targetSession, Collection<IMessagesStore.StoredMessage> messages)
broker/src/main/java/io/moquette/spi/impl/InternalRepublisher.java:39
Method
publishStored
(ClientSession clientSession, Queue<IMessagesStore.StoredMessage> publishedEvents)
broker/src/main/java/io/moquette/spi/impl/InternalRepublisher.java:56
Method
qos
(MqttQoS qos)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:51
Method
queue
(String clientID)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:720
Method
quitGroup
退出跨域群组 @param operator 操作者用户ID @param groupId 群组ID @param to_lines 消息同步到的线路列表 @param notify_message 通知消息 @return 退出结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MeshAdmin.java:314
Method
reasonCode
(byte reasonCode)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:529
Method
reasonCode
(byte reasonCode)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:677
Method
reasonCode
(byte reasonCode)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:705
Method
reasonString
(String reason)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:469
Method
recallCastMessage
(long messageUid, String operatorId)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:2810
Method
recallMessage
撤回跨域消息 @param operator 操作者用户ID @param messageId 消息ID @return 撤回结果 @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/MeshAdmin.java:186
Method
recallMessage
撤回频道消息 @param messageUid 消息UID @return 操作结果,返回被撤回消息的UID @throws Exception 请求失败时抛出异常
sdk/src/main/java/cn/wildfirechat/sdk/ChannelServiceApi.java:139
Method
recallMessage
(long messageUid, String operatorId, String clientId, boolean isAdmin, ByteBuf ackPayload)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:2654
Method
receiveMaximum
(int value)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:436
Method
refCnt
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPublishMessage.java:70
Method
registerAllExtensions
( com.google.protobuf.ExtensionRegistry registry)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:8
Method
registerCustomMessageContent
(Class<? extends MessageContent> cls)
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/MessageContentFactory.java:92
Method
reloadFriendRequestsFromDB
(HazelcastInstance hzInstance)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:703
Method
reloadFriendsFromDB
(HazelcastInstance hzInstance)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:648
Method
remoteIMError
(int code, String message)
common/src/main/java/cn/wildfirechat/pojos/mesh/MeshRestResult.java:57
Method
remoteMeshError
(int code, String message)
common/src/main/java/cn/wildfirechat/pojos/mesh/MeshRestResult.java:64
Method
removeAddedMember
<code>repeated .GroupMember added_member = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:18319
Method
removeChannel
<code>repeated .ChannelInfo channel = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:15199
Method
removeChannelHandlerContext
removeContext @param requestId
broker/src/main/java/com/xiaoleilu/loServer/handler/HttpFileServerController.java:66
Method
removeEldestEntry
(Map.Entry<String, Long> eldest)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:149
Method
removeEntry
<code>repeated .Robot entry = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:30890
Method
removeEntry
<code>repeated .InfoEntry entry = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:35172
Method
removeEntry
<code>repeated .UserSettingEntry entry = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:49651
Method
removeEntry
<code>repeated .Friend entry = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:51387
Method
removeEntry
<code>repeated .FriendRequest entry = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:52073
Method
removeEntry
<code>repeated .User entry = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:55485
Method
removeFavGroup
(final String groupId, final List<String> memberIds)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:1258
Method
removeGroupMember
(String groupId, List<String> groupMembers)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:2208
Method
removeGroupUserSettings
(String groupId, List<String> users)
broker/src/main/java/io/moquette/persistence/DatabaseStore.java:1415
Method
removeInfo
<code>repeated .GroupInfo info = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:37948
Method
removeInterceptHandler
(InterceptHandler interceptHandler)
broker/src/main/java/io/moquette/spi/impl/BrokerInterceptor.java:137
Method
removeInterceptHandler
(InterceptHandler interceptHandler)
broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java:763
Method
removeInterceptHandler
SPI method used by Broker embedded applications to remove intercept handlers. @param interceptHandler the handler to remove.
broker/src/main/java/io/moquette/server/Server.java:495
Method
removeMember
<code>repeated .GroupMember member = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:39202
Method
removeMembers
<code>repeated .GroupMember members = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:5403
Method
removeMenu
<code>repeated .ChannelMenu menu = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:8354
Method
removeMenu
<code>repeated .ChannelMenu menu = 12;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:10574
Method
removeMessage
<code>repeated .Message message = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:37196
Method
removeRequest
<code>repeated .UserRequest request = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:40448
Method
removeResult
<code>repeated .UserResult result = 1;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:41746
Method
removeSensitiveWords
(List<String> words)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:5059
Method
removeSubMenu
<code>repeated .ChannelMenu sub_menu = 9;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:7520
Method
responseInformation
(String value)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:499
Method
retain
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPublishMessage.java:75
Method
retainAvailable
(boolean retain)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:449
Method
retained
(boolean retained)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:46
Method
retainedDuplicate
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPublishMessage.java:60
Method
returnCode
(MqttConnectReturnCode returnCode)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:314
Method
roolback
()
broker/src/main/java/win/liyufan/im/DBUtil.java:314
Method
run
()
broker/src/main/java/io/moquette/server/netty/AutoFlushHandler.java:163
Method
saveAddFriendRequest
(String userId, WFCMessage.AddFriendRequest request, long[] head, boolean isAdmin, boolean isRobot)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:3722
Method
searchChannel
(String keyword, boolean buzzy, int page)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:4862
Method
searchMatching
Return a list of retained messages that satisfy the condition. @param condition the condition to match during the search. @return the coll
broker/src/main/java/io/moquette/spi/IMessagesStore.java:311
Method
searchMatching
(IMatchingCondition condition)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:5354
Method
searchUser
(String userId, String keyword, int searchType, int userType, int page, List<WFCMessage.User> users)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:3363
Method
secondPhaseAcknowledged
(int messageID)
broker/src/main/java/io/moquette/spi/ClientSession.java:148
Method
secondPhaseAcknowledged
(String clientID, int messageID)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:750
Method
sendBrokenUpload204Resonse
断点上传204应答 @param ctx @param contentRange
broker/src/main/java/com/xiaoleilu/loServer/handler/HttpResponseHelper.java:108
Method
sendConferenceRequest
发送会议相关请求 @param robotId 机器人ID @param clientId 客户端ID @param request 请求类型 @param sessionId 会话ID @param roomId 会议室ID @param data 请求数据 @param advance 是否高级
sdk/src/main/java/cn/wildfirechat/sdk/RobotService.java:606
Method
sendNotFound
发送404 Not Found @param msg 消息内容 @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:543
Method
sendRedirect
302 重定向 @param uri 重定向到的URI @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:510
Method
sendServerError
发送500 Internal Server Error @param msg 消息内容 @return ChannelFuture
broker/src/main/java/com/xiaoleilu/loServer/handler/Response.java:553
Method
serverKeepAlive
(int seconds)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:494
Method
serverReference
(String host)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:504
Method
sessionExpiryInterval
(long seconds)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:431
Method
sessionForClient
(String clientID)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:615
Method
sessionForClientAndUser
(String username, String clientID)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:602
Method
sessionForUser
(String username)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:658
Method
sessionPresent
(boolean sessionPresent)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:319
Method
sessionsStore
()
broker/src/main/java/io/moquette/persistence/MemoryStorageService.java:44
Method
setAddedMember
<code>repeated .GroupMember added_member = 2;</code>
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:18200
← previous
next →
8,401–8,500 of 9,418, ranked by callers