MCPcopy Create free account

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

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

MethodInterceptConnectionLostMessage
(String clientID, String username)
broker/src/main/java/io/moquette/interception/messages/InterceptConnectionLostMessage.java:24
MethodInterceptDisconnectMessage
(String clientID, String username)
broker/src/main/java/io/moquette/interception/messages/InterceptDisconnectMessage.java:24
MethodInterceptPublishMessage
(MqttPublishMessage msg, String clientID, String username)
broker/src/main/java/io/moquette/interception/messages/InterceptPublishMessage.java:28
MethodInternalRepublisher
(PersistentQueueMessageSender messageSender)
broker/src/main/java/io/moquette/spi/impl/InternalRepublisher.java:35
MethodLinkMessageContent
()
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/LinkMessageContent.java:29
MethodListenChannel
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:13973
MethodLoFileServer
(int port, IMessagesStore messagesStore)
broker/src/main/java/com/xiaoleilu/loServer/LoFileServer.java:42
MethodLoServer
(int port, int adminPort, IMessagesStore messagesStore, ISessionsStore sessionsStore)
broker/src/main/java/com/xiaoleilu/loServer/LoServer.java:45
MethodLoadRemoteMessages
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:63247
MethodLocationMessageContent
()
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/LocationMessageContent.java:28
MethodLoggingUtils
()
broker/src/main/java/io/moquette/logging/LoggingUtils.java:33
MethodMatchType
(String desc)
broker/src/main/java/win/liyufan/im/SensitiveFilter.java:15
MethodMeetingMinutesMessageContent
()
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/MeetingMinutesMessageContent.java:25
MethodMemoryConfig
(Properties properties)
broker/src/main/java/io/moquette/server/config/MemoryConfig.java:29
MethodMemoryMessagesStore
(Server server, DatabaseStore databaseStore)
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java:237
MethodMemorySessionStore
(Server server, DatabaseStore databaseStore)
broker/src/main/java/io/moquette/persistence/MemorySessionStore.java:300
MethodMemoryStorageService
(IConfig props, ThreadPoolExecutorWrapper scheduler, Server server)
broker/src/main/java/io/moquette/persistence/MemoryStorageService.java:33
MethodMeshRestCode
(int code, String msg)
common/src/main/java/cn/wildfirechat/pojos/mesh/MeshRestResult.java:32
MethodMeshRestResult
()
common/src/main/java/cn/wildfirechat/pojos/mesh/MeshRestResult.java:92
MethodMessage
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:25501
MethodMessageBundle
()
broker/src/main/java/win/liyufan/im/MessageBundle.java:29
MethodMessageContent
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:15539
MethodMessageGUID
(String guid)
broker/src/main/java/io/moquette/spi/MessageGUID.java:29
MethodMessageMetricsHandler
(MessageMetricsCollector collector)
broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsHandler.java:38
MethodMessagesPublisher
(ConnectionDescriptorStore connectionDescriptors, ISessionsStore sessionsStore, P
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java:99
MethodModifiedMqttPubAckMessage
(MqttFixedHeader mqttFixedHeader, MqttMessageIdVariableHeader variableHeader, ByteBuf payload)
broker/src/main/java/win/liyufan/im/extended/mqttmessage/ModifiedMqttPubAckMessage.java:9
MethodModifyChannelInfo
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:10710
MethodModifyGroupInfoRequest
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:31875
MethodModifyGroupMemberAlias
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:44865
MethodModifyGroupMemberExtra
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:46025
MethodModifyMyInfoRequest
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:34607
MethodModifyUserSettingReq
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:47965
MethodMqttCodecUtil
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttCodecUtil.java:130
MethodMqttConnAckMessage
(MqttFixedHeader mqttFixedHeader, MqttConnAckVariableHeader variableHeader)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnAckMessage.java:24
MethodMqttConnAckVariableHeader
(MqttConnectReturnCode connectReturnCode, boolean sessionPresent)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnAckVariableHeader.java:32
MethodMqttConnectAckPayload
( byte[] data)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnectAckPayload.java:28
MethodMqttConnectMessage
( MqttFixedHeader mqttFixedHeader, MqttConnectVariableHeader variableHeader,
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnectMessage.java:24
MethodMqttConnectPayload
@deprecated use {@link MqttConnectPayload#MqttConnectPayload(String, MqttProperties, String, byte[], String, byte[])} instead
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnectPayload.java:41
MethodMqttConnectReturnCode
(byte byteValue)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnectReturnCode.java:70
MethodMqttConnectVariableHeader
( String name, int version, boolean hasUserName, boolean hasPa
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConnectVariableHeader.java:37
MethodMqttConnectionMetrics
(long readBytes, long writtenBytes, long readMessages, long writtenMessages)
broker/src/main/java/io/moquette/connections/MqttConnectionMetrics.java:29
MethodMqttConstant
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttConstant.java:20
MethodMqttDecoder
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java:59
MethodMqttEncoder
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java:43
MethodMqttFixedHeader
( MqttMessageType messageType, boolean isDup, MqttQoS qosLevel,
broker/src/main/java/io/netty/handler/codec/mqtt/MqttFixedHeader.java:34
MethodMqttIdentifierRejectedException
Creates a new instance
broker/src/main/java/io/netty/handler/codec/mqtt/MqttIdentifierRejectedException.java:30
MethodMqttMessage
(MqttFixedHeader mqttFixedHeader)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessage.java:43
MethodMqttMessageBuilders
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageBuilders.java:760
MethodMqttMessageFactory
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageFactory.java:101
MethodMqttMessageIdAndPropertiesVariableHeader
(int messageId, MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageIdAndPropertiesVariableHeader.java:28
MethodMqttMessageIdVariableHeader
(int messageId)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageIdVariableHeader.java:36
MethodMqttMessageType
(int value)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttMessageType.java:57
MethodMqttProperties
()
broker/src/main/java/io/netty/handler/codec/mqtt/MqttProperties.java:285
MethodMqttProperty
(int propertyId, T value)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttProperties.java:121
MethodMqttPropertyType
(int value)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttProperties.java:81
MethodMqttPubAckMessage
(MqttFixedHeader mqttFixedHeader, MqttMessageIdVariableHeader variableHeader)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPubAckMessage.java:24
MethodMqttPubReplyMessageVariableHeader
(int messageId, byte reasonCode, MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPubReplyMessageVariableHeader.java:31
MethodMqttPublishMessage
( MqttFixedHeader mqttFixedHeader, MqttPublishVariableHeader variableHeader,
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPublishMessage.java:28
MethodMqttPublishVariableHeader
(String topicName, int packetId)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttPublishVariableHeader.java:30
MethodMqttQoS
(int value)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttQoS.java:26
MethodMqttReasonCodeAndPropertiesVariableHeader
(byte reasonCode, MqttProperties properties)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttReasonCodeAndPropertiesVariableHeader.java:31
MethodMqttSubAckMessage
( MqttFixedHeader mqttFixedHeader, MqttMessageIdAndPropertiesVariableHeader variableHe
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubAckMessage.java:24
MethodMqttSubAckPayload
(int... reasonCodes)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubAckPayload.java:33
MethodMqttSubscribeMessage
( MqttFixedHeader mqttFixedHeader, MqttMessageIdAndPropertiesVariableHeader variableHe
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubscribeMessage.java:25
MethodMqttSubscribePayload
(List<MqttTopicSubscription> topicSubscriptions)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubscribePayload.java:31
MethodMqttSubscriptionOption
(MqttQoS qos, boolean noLocal, boolean ret
broker/src/main/java/io/netty/handler/codec/mqtt/MqttSubscriptionOption.java:61
MethodMqttTopicSubscription
(String topicFilter, MqttQoS qualityOfService)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttTopicSubscription.java:30
MethodMqttUnacceptableProtocolVersionException
Creates a new instance
broker/src/main/java/io/netty/handler/codec/mqtt/MqttUnacceptableProtocolVersionException.java:31
MethodMqttUnsubAckMessage
(MqttFixedHeader mqttFixedHeader, MqttMessageIdAndPropertiesVariableHeader vari
broker/src/main/java/io/netty/handler/codec/mqtt/MqttUnsubAckMessage.java:25
MethodMqttUnsubAckPayload
(short... unsubscribeReasonCodes)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttUnsubAckPayload.java:42
MethodMqttUnsubscribeMessage
( MqttFixedHeader mqttFixedHeader, MqttMessageIdAndPropertiesVariableHeader variableHe
broker/src/main/java/io/netty/handler/codec/mqtt/MqttUnsubscribeMessage.java:25
MethodMqttUnsubscribePayload
(List<String> topics)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttUnsubscribePayload.java:31
MethodMqttVersion
(String protocolName, byte protocolLevel)
broker/src/main/java/io/netty/handler/codec/mqtt/MqttVersion.java:35
MethodMultiCallOngoingMessageContent
()
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/MultiCallOngoingMessageContent.java:31
MethodMultiCastMessage
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:64116
MethodMultiMessageResult
()
common/src/main/java/cn/wildfirechat/pojos/MultiMessageResult.java:15
MethodNettyMQTTHandler
(ProtocolProcessor processor)
broker/src/main/java/io/moquette/server/netty/NettyMQTTHandler.java:35
MethodNettyUtils
()
broker/src/main/java/io/moquette/server/netty/NettyUtils.java:72
MethodNotifyMessage
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:35303
MethodNotifyRecallMessage
(com.google.protobuf.GeneratedMessage.Builder<?> builder)
common/src/main/java/cn/wildfirechat/proto/WFCMessage.java:58982
MethodOutputChatroomBlackInfo
()
common/src/main/java/cn/wildfirechat/pojos/OutputChatroomBlackInfos.java:12
MethodOutputClient
()
common/src/main/java/cn/wildfirechat/pojos/OutputClient.java:17
MethodOutputCreateChannel
(String targetId, String secret)
common/src/main/java/cn/wildfirechat/pojos/OutputCreateChannel.java:18
MethodOutputCreateChatroom
()
common/src/main/java/cn/wildfirechat/pojos/OutputCreateChatroom.java:15
MethodOutputCreateDevice
()
common/src/main/java/cn/wildfirechat/pojos/OutputCreateDevice.java:16
MethodOutputCreateGroupResult
(String group_id)
common/src/main/java/cn/wildfirechat/pojos/OutputCreateGroupResult.java:20
MethodOutputCreateRobot
()
common/src/main/java/cn/wildfirechat/pojos/OutputCreateRobot.java:15
MethodOutputCreateUser
()
common/src/main/java/cn/wildfirechat/pojos/OutputCreateUser.java:15
MethodOutputDevice
()
common/src/main/java/cn/wildfirechat/pojos/OutputDevice.java:23
MethodOutputGetAlias
()
common/src/main/java/cn/wildfirechat/pojos/OutputGetAlias.java:17
MethodOutputGetChatroomInfo
(String chatroomId, int memberCount, WFCMessage.ChatroomInfo chatroomInfo)
common/src/main/java/cn/wildfirechat/pojos/OutputGetChatroomInfo.java:26
MethodOutputGetIMTokenData
()
common/src/main/java/cn/wildfirechat/pojos/OutputGetIMTokenData.java:8
MethodOutputLoginData
()
common/src/main/java/cn/wildfirechat/pojos/OutputLoginData.java:17
MethodOutputNotifyChannelSubscribeStatus
()
common/src/main/java/cn/wildfirechat/pojos/OutputNotifyChannelSubscribeStatus.java:16
MethodOutputRecallMessageData
()
common/src/main/java/cn/wildfirechat/pojos/OutputRecallMessageData.java:17
MethodOutputRouteData
()
common/src/main/java/cn/wildfirechat/pojos/OutputRouteData.java:19
MethodOutputStringList
()
common/src/main/java/cn/wildfirechat/pojos/OutputStringList.java:8
MethodOutputTimestamp
()
common/src/main/java/cn/wildfirechat/pojos/OutputTimestamp.java:14
MethodOutputUserStatus
()
common/src/main/java/cn/wildfirechat/pojos/OutputUserStatus.java:14
MethodPTTSoundMessageContent
()
sdk/src/main/java/cn/wildfirechat/sdk/messagecontent/PTTSoundMessageContent.java:21
← previousnext →3,101–3,200 of 9,418, ranked by callers