Lines Matching refs:options
6 constructor(options) { argument
8 if (!options || !options.host) {
12 this.options = { class in MQTTClient.constructor
13 host: options.host,
14 port: options.port || 1883,
15 client_id: options.clientId || this._getRandomClientId(),
16 username: options.username || '',
17 password: options.password || '',
18 keepalive_interval: options.keepalive_interval || 60
21 this._fail = options.fail || function(){};
22 this._success = options.success || function(){};
51 this.mqttInstance = __native.MQTT.start(this.options, cb.bind(this));
60 subscribe(options) { argument
61 if (!this.mqttInstance || !options || !options.topic) {
70 …var ret = __native.MQTT.subscribe(this.mqttInstance, options.topic, options.qos || 0, function(top…
74 if(typeof options.fail === 'function') {
75 options.fail();
80 if(typeof options.success === 'function') {
81 options.success();
86 unsubscribe(options) { argument
87 if (!this.mqttInstance || !options || !options.topic) {
96 var ret = __native.MQTT.unsubscribe(this.mqttInstance, options.topic, function() {
99 if(typeof options.fail === 'function') {
100 options.fail();
106 if(typeof options.success === 'function') {
107 options.success();
111 publish(options) { argument
112 if (!this.mqttInstance || !options || !options.topic || !options.message) {
121 …__native.MQTT.publish(this.mqttInstance, options.topic, options.message, options.qos || 0, functio…
123 if(typeof options.fail === 'function') {
124 options.fail();
126 this.emit('error', options.topic);
130 if(typeof options.success === 'function') {
131 options.success();
151 function createClient(options) { argument
152 return new MQTTClient(options);