OptionalALPNProtocols
ALPNProtocols?:
| Buffer<ArrayBufferLike>
| Uint8Array<ArrayBufferLike>
| string[]
| Buffer<ArrayBufferLike>[]
| Uint8Array<ArrayBufferLike>[]
Optionalauth
auth?: string
OptionalauthPacket
authPacket?: Partial<IAuthPacket>
OptionalautoAssignTopicAlias
autoAssignTopicAlias?: boolean
OptionalautoReconnect
autoReconnect?: boolean
OptionalautoUseTopicAlias
autoUseTopicAlias?: boolean
Optionalbinary
binary?: boolean
brokerUrl
brokerUrl: string
OptionalbrowserBufferSize
browserBufferSize?: number
OptionalbrowserBufferTimeout
browserBufferTimeout?: number
Optionalca
ca?: string | Buffer<ArrayBufferLike> | string[] | Buffer<ArrayBufferLike>[]
OptionalcaPaths
caPaths?: string | string[]
Optionalcert
cert?: string | Buffer<ArrayBufferLike> | string[] | Buffer<ArrayBufferLike>[]
OptionalcertPath
certPath?: string
Optionalclean
clean?: boolean
clientId
clientId: string
OptionalconnectTimeout
connectTimeout?: number
OptionalcreateWebsocket
createWebsocket?: (
url: string,
websocketSubProtocols: string[],
options: IClientOptions,
) => any
OptionalcustomHandleAcks
customHandleAcks?: AckHandler
OptionaldefaultProtocol
defaultProtocol?: MqttProtocol
Optionalencoding
encoding?: BufferEncoding
OptionalforceNativeWebSocket
forceNativeWebSocket?: boolean
Optionalhost
host?: string
Optionalhostname
hostname?: string
OptionalincomingStore
incomingStore?: IStore
Optionalkeepalive
keepalive?: number
Optionalkey
key?:
| string
| any[]
| Buffer<ArrayBufferLike>
| string[]
| Buffer<ArrayBufferLike>[]
OptionalkeyPath
keyPath?: string
Optionallog
log?: (...args: any[]) => void
OptionalmanualConnect
manualConnect?: boolean
OptionalmessageIdProvider
messageIdProvider?: IMessageIdProvider
OptionalobjectMode
objectMode?: boolean
OptionaloutgoingStore
outgoingStore?: IStore
Optionalpassword
password?: string | Buffer<ArrayBufferLike>
Optionalpath
path?: string
Optionalport
port?: number
Optionalproperties
properties?: {
authenticationData?: Buffer<ArrayBufferLike>;
authenticationMethod?: string;
maximumPacketSize?: number;
receiveMaximum?: number;
requestProblemInformation?: boolean;
requestResponseInformation?: boolean;
sessionExpiryInterval?: number;
topicAliasMaximum?: number;
userProperties?: UserProperties;
}
Optionalprotocol
protocol?: MqttProtocol
OptionalprotocolId
protocolId?: "MQTT" | "MQIsdp"
OptionalprotocolVersion
protocolVersion?: 5 | 3 | 4
Optionalquery
query?: Record<string, string>
OptionalqueueQoSZero
queueQoSZero?: boolean
OptionalreconnectInterval
reconnectInterval?: number
OptionalreconnectOnConnackError
reconnectOnConnackError?: boolean
OptionalreconnectPeriod
reconnectPeriod?: number
OptionalrejectUnauthorized
rejectUnauthorized?: boolean
OptionalreschedulePings
reschedulePings?: boolean
Optionalresubscribe
resubscribe?: boolean
Optionalservername
servername?: string
Optionalservers
servers?: {
host: string;
port: number;
protocol?: "wss" | "ws" | "mqtt" | "mqtts" | "tcp" | "ssl" | "wx" | "wxs";
}[]
OptionalsocksProxy
socksProxy?: string
OptionalsocksTimeout
socksTimeout?: number
OptionalsubscribeBatchSize
subscribeBatchSize?: number
OptionaltimerVariant
timerVariant?: TimerVariant | Timer
OptionaltopicPrefix
topicPrefix?: string
transformWsUrl?: (
url: string,
options: IClientOptions,
client: MqttClient,
) => string
OptionalunixSocket
unixSocket?: boolean
Optionalusername
username?: string
Optionalwill
will?: {
payload: string | Buffer<ArrayBufferLike>;
properties?: {
contentType?: string;
correlationData?: Buffer<ArrayBufferLike>;
messageExpiryInterval?: number;
payloadFormatIndicator?: boolean;
responseTopic?: string;
userProperties?: UserProperties;
willDelayInterval?: number;
};
qos?: QoS;
retain?: boolean;
topic: string;
}
OptionalwriteCache
writeCache?: boolean
OptionalwsOptions
wsOptions?: ClientOptions | ClientRequestArgs | DuplexOptions