import { connect } from 'mqtt';

var client = connect('mqtt://mqtt.timovolkmann.de')

function publish(topic, message) {
  if (!client.connected) {
    client.reconnect();
  }
  client.publish(topic, message, () => console.log('message sent...'))
}

module.exports = { publish }