| 123456789101112131415161718192021222324 |
- 'use strict'
- var mqtt = require('../..')
- var path = require('path')
- var fs = require('fs')
- var KEY = fs.readFileSync(path.join(__dirname, '..', '..', 'test', 'helpers', 'tls-key.pem'))
- var CERT = fs.readFileSync(path.join(__dirname, '..', '..', 'test', 'helpers', 'tls-cert.pem'))
- var PORT = 8443
- var options = {
- port: PORT,
- key: KEY,
- cert: CERT,
- rejectUnauthorized: false
- }
- var client = mqtt.connect(options)
- client.subscribe('messages')
- client.publish('messages', 'Current time is: ' + new Date())
- client.on('message', function (topic, message) {
- console.log(message)
- })
|
