Class MQTT2Acceptor

Hierarchy

EventEmitter
- MQTT2Acceptor

Index

Constructors

constructor

Properties

Constructors

constructor

new MQTT2Acceptor(opts: AcceptorOpts, cb: function): MQTT2Acceptor

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:47
Parameters
- opts: AcceptorOpts
- cb: function
  - - (tracer: Tracer, msg?: any, cb?: Function): void
    - Parameters
      - tracer: Tracer
      - Optional msg: any
      - Optional cb: Function
      Returns void
Returns MQTT2Acceptor

Properties

_interval

_interval: any

bufferMsg

bufferMsg: any

cb

cb: any

closed

closed: boolean

inited

inited: boolean

interval

interval: number

msgQueues

msgQueues: any

rpcDebugLog

rpcDebugLog: any

rpcLogger

rpcLogger: any

server

server: Server

services

services: any

servicesMap

servicesMap: any

sockets

sockets: any

Static defaultMaxListeners

defaultMaxListeners: number

Methods

addListener

addListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.addListener

Overrides EventEmitter.addListener
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:907
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

cloneError

cloneError(origin: object): object

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:169
Parameters
- origin: object
  - msg: string
  - stack: object
Returns object
- msg: string
- stack: object

close

close(): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:142
Returns void

doSend

doSend(socket: any, msg: Msg): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:273
Parameters
- socket: any
- msg: Msg
Returns void

doSendHandshake

doSendHandshake(socket: any, msg: string): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:282
Parameters
- socket: any
- msg: string
Returns void

emit

emit(event: string | symbol, ...args: any[]): boolean

Inherited from EventEmitter.emit

Overrides EventEmitter.emit
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:917
Parameters
- event: string | symbol
- Rest ...args: any[]
Returns boolean

enqueue

enqueue(socket: any, acceptor: MQTT2Acceptor, msg: object): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:238
Parameters
- socket: any
- acceptor: MQTT2Acceptor
- msg: object
  - [key: string]: any
Returns void

eventNames

eventNames(): Array<string | symbol>

Inherited from EventEmitter.eventNames

Overrides EventEmitter.eventNames
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:918
Returns Array<string | symbol>

flush

flush(acceptor: MQTT2Acceptor): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:249
Parameters
- acceptor: MQTT2Acceptor
Returns void

getMaxListeners

getMaxListeners(): number

Inherited from EventEmitter.getMaxListeners

Overrides EventEmitter.getMaxListeners
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:915
Returns number

listen

listen(port: string | number): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:64
Parameters
- port: string | number
Returns void

listenerCount

listenerCount(type: string | symbol): number

Inherited from EventEmitter.listenerCount

Overrides EventEmitter.listenerCount
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:919
Parameters
- type: string | symbol
Returns number

listeners

listeners(event: string | symbol): Function[]

Inherited from EventEmitter.listeners

Overrides EventEmitter.listeners
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:916
Parameters
- event: string | symbol
Returns Function[]

on

on(event: string | symbol, listener: function): this

Inherited from EventEmitter.on

Overrides EventEmitter.on
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:908
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

onSocketClose

onSocketClose(socket: any): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:158
Parameters
- socket: any
Returns void

once

once(event: string | symbol, listener: function): this

Inherited from EventEmitter.once

Overrides EventEmitter.once
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:909
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

prependListener

prependListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.prependListener

Overrides EventEmitter.prependListener
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:910
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

prependOnceListener

prependOnceListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.prependOnceListener

Overrides EventEmitter.prependOnceListener
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:911
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

processMsg

processMsg(socket: object, acceptor: MQTT2Acceptor, pkg: AcceptorPkg): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:179
Parameters
- socket: object
- acceptor: MQTT2Acceptor
- pkg: AcceptorPkg
Returns void

processMsgs

processMsgs(socket: any, acceptor: MQTT2Acceptor, pkgs: Array<AcceptorPkg>): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:230
Parameters
- socket: any
- acceptor: MQTT2Acceptor
- pkgs: Array<AcceptorPkg>
Returns void

removeAllListeners

removeAllListeners(event?: string | symbol): this

Inherited from EventEmitter.removeAllListeners

Overrides EventEmitter.removeAllListeners
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:913
Parameters
- Optional event: string | symbol
Returns this

removeListener

removeListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.removeListener

Overrides EventEmitter.removeListener
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:912
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

sendHandshake

sendHandshake(socket: any, acceptor: MQTT2Acceptor): void

- Defined in rpc-server/acceptors/mqtt2-acceptor.ts:291
Parameters
- socket: any
- acceptor: MQTT2Acceptor
Returns void

setMaxListeners

setMaxListeners(n: number): this

Inherited from EventEmitter.setMaxListeners

Overrides EventEmitter.setMaxListeners
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:914
Parameters
- n: number
Returns this

Static listenerCount

listenerCount(emitter: EventEmitter, event: string | symbol): number

Inherited from EventEmitter.listenerCount
- Defined in C:/pinus/pinus/node_modules/@types/node/index.d.ts:904
Parameters
- emitter: EventEmitter
- event: string | symbol
Returns number