File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -270,7 +270,7 @@ function MqttClient (streamBuilder, options) {
270
270
debug ( 'MqttClient :: options.keepalive' , options . keepalive )
271
271
debug ( 'MqttClient :: options.reconnectPeriod' , options . reconnectPeriod )
272
272
debug ( 'MqttClient :: options.rejectUnauthorized' , options . rejectUnauthorized )
273
- debug ( 'MqttClient :: options.topicAliasMaximum' , options . topicAliasMaximum )
273
+ debug ( 'MqttClient :: options.properties. topicAliasMaximum' , options . properties . topicAliasMaximum )
274
274
275
275
this . options . clientId = ( typeof options . clientId === 'string' ) ? options . clientId : defaultId ( )
276
276
@@ -320,11 +320,11 @@ function MqttClient (streamBuilder, options) {
320
320
// True if connection is first time.
321
321
this . _firstConnection = true
322
322
323
- if ( options . topicAliasMaximum > 0 ) {
324
- if ( options . topicAliasMaximum > 0xffff ) {
325
- debug ( 'MqttClient :: options.topicAliasMaximum is out of range' )
323
+ if ( options . properties && options . properties . topicAliasMaximum > 0 ) {
324
+ if ( options . properties . topicAliasMaximum > 0xffff ) {
325
+ debug ( 'MqttClient :: options.properties. topicAliasMaximum is out of range' )
326
326
} else {
327
- this . topicAliasRecv = new TopicAliasRecv ( options . topicAliasMaximum )
327
+ this . topicAliasRecv = new TopicAliasRecv ( options . properties . topicAliasMaximum )
328
328
}
329
329
}
330
330
You can’t perform that action at this time.
0 commit comments