Lines Matching refs:options
5 constructor(options) { argument
7 if (!options || !options.host) {
11 this.options = { class in MQTTClient.constructor
12 host: options.host,
13 port: options.port || 1883,
14 client_id: options.clientId || this._getRandomClientId(),
15 username: options.username || '',
16 password: options.password || '',
17 keepalive_interval: options.keepalive_interval || 60
20 this._fail = options.fail || function () { };
21 this._success = options.success || function () { };
32 MQTT.start(this.options, function (res) {
54 subscribe(options) { argument
55 if (!this.mqttInstance || !options || !options.topic) {
64 var ret = MQTT.subscribe(this.mqttInstance, options.topic, options.qos || 0);
66 if (typeof options.fail === 'function') {
67 options.fail();
72 if (typeof options.success === 'function') {
73 options.success();
78 unsubscribe(options) { argument
79 if (!this.mqttInstance || !options || !options.topic) {
88 var ret = MQTT.unsubscribe(this.mqttInstance, options.topic);
90 if (typeof options.fail === 'function') {
91 options.fail();
97 if (typeof options.success === 'function') {
98 options.success();
102 publish(options) { argument
103 if (!this.mqttInstance || !options || !options.topic || !options.message) {
112 … MQTT.publish(this.mqttInstance, options.topic, options.message, options.qos || 0, function (ret) {
114 if (typeof options.fail === 'function') {
115 options.fail();
117 this.emit('error', options.topic);
121 if (typeof options.success === 'function') {
122 options.success();
142 export function createClient(options) { argument
143 return new MQTTClient(options);