mqttjs bwt mesin

// bikin file mqtt.js di middleware/RMQ isinya gini

import mqttjs from 'mqtt'
import config from './config_rmq'

let mqtt = mqttjs.connect(config.rmqAddress, {
  username: config.rmqUsername,
  password: config.rmqPassword,
  clientId: 'MesinAbsensi-' + Math.random().toString(16).substr(2, 8) + '-Assalam-',
  protocolId: 'MQTT',
  keepalive: 1,
  reconnectPeriod: 100 * 1
})

export default mqtt


// Di dashboard.vue isinya tambahin gini
import mesin from '../middleware/rmq/mqtt'

//tambahkan method ini di dalem export default
beforeCreate: function () {
    mesin.on('connect', function () {
      mesin.subscribe('absensi.service', function (err) {
        if (!err) {
          console.log('Subscribe to RMQ PPTIK Success')
        } else if (err) {
          console.log(err)
        }
      })
    })
  },

data () {
    return {
      datamesin: null
    }
  },
methods: {
    filldata: function () {
      let ini = this
      rmq.on('message', function (topic, message) {
        console.log(message.toString())
        let data = message.toString()
        ini.datamesin = data
      })
    }
  },
  mounted: function () {
    this.filldata()
  }