Pomelo API
v2.3.0
Modules
appUtils
Methods
defaultConfiguration
loadDefaultComponents
optComponents
startByType
stopComps
lib/util/seq-queue
ModuleUtil
Methods
loadModules
startModules
startModules
utils
Methods
arrayDiff
checkPort
endsWith
extends
format
hasChineseChar
headHandler
invokeCallback
isLocal
isObject
loadCluster
ping
size
startsWith
unicodeToUtf8
Classes
Application
Members
STATE_INITED
STATE_START
STATE_STARTED
STATE_STOPED
backendSessionService
channelService
components
curServer
mode
serverId
serverType
sessionService
startTime
Methods
rpcInvoke
addCrons
addServers
after
afterStart
before
beforeStopHook
configure
configureLogger
disable
disabled
enable
enabled
filter
get
getBackendSessionService
getBase
getCfgPath
getCfgSync
getChannelService
getCurServer
getMaster
getRoutes
getServerById
getServerFromConfig
getServerId
getServers
getServersByType
getServersFromConfig
getServerType
getServerTypes
getSessionService
globalAfter
globalBefore
globalFilter
init
isBackend
isFrontend
isMaster
load
loadConfig
loadConfigBaseApp
registerAdmin
removeCrons
removeServers
replaceServers
require
route
rpcAfter
rpcBefore
rpcFilter
set
start
stop
tr
tr1
transaction
use
BackendSession
Methods
bind
export
get
push
pushAll
set
unbind
BackendSessionService
Methods
bind
get
getByUid
kickBySid
kickByUid
push
pushAll
unbind
BaseApp
Members
app
cfg
serverId
serverType
Methods
setRoute
setupPlugin
setupSet
BaseComponent
Methods
afterStart
start
stop
BaseCron
BaseFilter
Methods
after
before
BaseGameHandler
BaseGameRemote
BaseLifecycle
Methods
afterStartAll
afterStartup
beforeShutdown
beforeStartup
Channel
Methods
add
destroy
getMember
getMembers
getUserAmount
leave
pushMessage
ChannelService
Methods
broadcast
createChannel
destroyChannel
getChannel
pushMessageByUids
ComponentDictionary
Members
cusRouteMap
Methods
start
ComponentProtobuf
Methods
stop
ComponentProxy
Methods
addServers
afterStart
removeServers
replaceServers
rpcInvoke
start
ComponentPushScheduler
Methods
afterStart
schedule
stop
ComponentRemote
Methods
start
stop
ComponentSession
ConnectionService
Methods
addLoginedUser
decreaseConnectionCount
getConnectionInfo
getStatisticsInfo
increaseConnectionCount
removeLoginedUser
updateUserInfo
Connector
Methods
afterStart
start
stop
CountDownLatch
Methods
done
FilterHandlerSerial
Methods
after
before
FilterHandlerTime
Methods
after
before
FilterHandlerTimeout
Methods
after
before
FilterHandlerTooBusy
Methods
before
FilterRpcLog
Methods
after
before
FilterToobusy
Methods
before
FrontendSession
Methods
export
HandlerService
Methods
getHandler
handle
hybridConnector
Methods
start
Processor
Socket
Switcher
MasterComp
Methods
start
stop
Monitor
Methods
start
stop
MonitorComp
Methods
start
stop
Adaptor
Methods
publish
Connector
Methods
start
Socket
Pomelo
Members
app
components
connectors
events
filters
pushSchedulers
rpcFilters
version
Methods
createApp
SeqQueue
Methods
_next
close
push
Server
Methods
addCrons
globalHandle
handle
removeCrons
start
stop
ServerComp
Methods
afterStart
globalHandle
handle
start
stop
ServiceFilter
Methods
after
afterFilter
before
beforeFilter
Session
Methods
bind
closed
get
remove
send
sendBatch
set
unbind
SessionService
Methods
bind
create
forEachBindedSession
forEachSession
get
getByUid
getClientAddressBySessionId
getSessionsCount
import
importAll
kick
kickBySessionId
remove
sendMessage
sendMessageByUid
unbind
SexPomeloI18n
Methods
tr
tr1
Connector
Methods
decode
start
stop
Socket
Connector
Socket
Methods
send
Namespaces
hybridConnector
MqttConnector
Members
module.exports.codes
module.exports.types
Methods
module.exports.publish
SexPomelo
Members
Application
BaseApp
BaseComponent
BaseFilter
Cron
GameHandler
GameRemote
Lifecycle
SioConnector
UdpConnector
Interfaces
Component
Methods
afterStart
start
stop
Filter
Methods
after
before
LifeCycle
Methods
afterStartAll
afterStartup
beforeShutdown
beforeStartup
Global
AutoFilters
AutoRpcFilters
Command
configure
Connection
create
DefaultComponents
DefaultConnectors
PluginCfg
RouteArg
RouteMsg
ServerInfo
SexAppCfg
MqttConnector
.
Socket
()
new
Socket
()
lib/connectors/mqttsocket.js
,
line 15