var connected = false; // WebSocket connect url //const WebSocket_URL = 'wss://univalleiot.ga:8094/mqtt' //wss es cunado es seguro const WebSocket_URL = 'ws://broker.emqx.io:8083/mqtt' //ws es cunado es seguro //const WebSocket_URL = 'wss://54.94.246.243:8094/mqtt' //wss es cunado es seguro const client = mqtt.connect(WebSocket_URL, options) client.on('connect', () => { console.log('Mqtt conectado por WS! Exito!') client.subscribe('terapiaNinosEnviar', { qos: 0 }, (error) => { if (!error) { console.log('Suscripción exitosa!') }else{ console.log('Suscripción fallida!') } }) // publish(topic, payload, options/callback) client.publish('fabrica', 'esto es un verdadero éxito', (error) => { console.log(error || 'Mensaje enviado!!!') }) }) client.on('message', (topic, message) => { console.log('Mensaje recibido bajo tópico: ', topic, ' -> ', message.toString()) process_msg(topic, message); }) client.on('reconnect', (error) => { console.log('Error al reconectar', error) }) client.on('error', (error) => { console.log('Error de conexión:', error) })