config for MQTT Broker
*/
let ascoltatore = {
//using ascoltatore
type: 'mongo',
url: 'mongodb://localhost:27017/mqtt',
pubsubCollection: 'ascoltatori',
mongo: {}
};
let settings = {
port: 1883, // 8883 for ssl
backend: ascoltatore,
persistence: {
factory: mosca.persistence.Mongo,
url: 'mongodb://localhost:27017/mqtt'
}
};
let mqttBroServer = new mosca.Server(settings); // mqttBroServer i.e, MQTT BROCKER SERVER
/**
only for MQTT brocker server
*/
mqttBroServer.on('ready', () => {
console.log(Mosca Server Listening on Port ${settings.port});
})
/**
MQTT brocker server
*/
// Sending data from mosca to clients
let packet = {
topic: 'myTopic',
payload: 'qjkdhcqhrbqwuoaehdQYFNHOGWAQLJWRHVBQUIWBGEIOQCBWIEUVVYECQTBUPEIRBCUYWNGJDSHGBUHWFEYRVBGEWOB', // or a Buffer
qos: 1, // 0, 1, or 2
retain: false // or true
};
mqttBroServer.on('connection', function (client) {
console.log(client);
console.log('client connected', client.id);
});
// fired when a message is received
mqttBroServer.on('published', function (packet, client) {
console.log('Published', packet.payload);
});
i this code with this error.
:\iot\remote\server\node_modules\ascoltatori\lib\mongo_ascoltatore.js:113
this.collection.insert(messageObj, { w: 1 }, done);
^
TypeError: Cannot read property 'insert' of undefined
at MongoAscoltatore.publish (E:\iot\remote\server\node_modules\ascoltatori\lib\mongo_ascoltatore.js:113:19)
at MongoAscoltatore.newPublish (E:\iot\remote\server\node_modules\ascoltatori\lib\abstract_ascoltatore.js:144:20)
at E:\iot\remote\server\node_modules\mosca\lib\server.js:383:22
at Server.storePacket (E:\iot\remote\server\node_modules\mosca\lib\server.js:488:5)
at Server.publish (E:\iot\remote\server\node_modules\mosca\lib\server.js:377:8)
at Object. (E:\iot\remote\server\mqtt.js:44:15)
at Module._compile (internal/modules/cjs/loader.js:688:30)
at Object.Module._extensions..js (internal/modules/cjs/loader.js:699:10)
at Module.load (internal/modules/cjs/loader.js:598:32)
at tryModuleLoad (internal/modules/cjs/loader.js:537:12)
at Function.Module._load (internal/modules/cjs/loader.js:529:3)
at Function.Module.runMain (internal/modules/cjs/loader.js:741:12)
at startup (internal/bootstrap/node.js:285:19)
at bootstrapNodeJSCore (internal/bootstrap/node.js:739:3)
[nodemon] app crashed - waiting for file changes before starting...
'use strict' const mosca = require('mosca');
/**
let settings = { port: 1883, // 8883 for ssl backend: ascoltatore, persistence: { factory: mosca.persistence.Mongo, url: 'mongodb://localhost:27017/mqtt' } };
let mqttBroServer = new mosca.Server(settings); // mqttBroServer i.e, MQTT BROCKER SERVER
/**
Mosca Server Listening on Port ${settings.port}); })/**
mqttBroServer.publish(packet, null, ()=>{ console.log('published'); });
mqttBroServer.on('connection', function (client) { console.log(client); console.log('client connected', client.id); });
// fired when a message is received mqttBroServer.on('published', function (packet, client) { console.log('Published', packet.payload); });
i this code with this error. :\iot\remote\server\node_modules\ascoltatori\lib\mongo_ascoltatore.js:113 this.collection.insert(messageObj, { w: 1 }, done); ^
TypeError: Cannot read property 'insert' of undefined at MongoAscoltatore.publish (E:\iot\remote\server\node_modules\ascoltatori\lib\mongo_ascoltatore.js:113:19) at MongoAscoltatore.newPublish (E:\iot\remote\server\node_modules\ascoltatori\lib\abstract_ascoltatore.js:144:20) at E:\iot\remote\server\node_modules\mosca\lib\server.js:383:22 at Server.storePacket (E:\iot\remote\server\node_modules\mosca\lib\server.js:488:5) at Server.publish (E:\iot\remote\server\node_modules\mosca\lib\server.js:377:8) at Object. (E:\iot\remote\server\mqtt.js:44:15)
at Module._compile (internal/modules/cjs/loader.js:688:30)
at Object.Module._extensions..js (internal/modules/cjs/loader.js:699:10)
at Module.load (internal/modules/cjs/loader.js:598:32)
at tryModuleLoad (internal/modules/cjs/loader.js:537:12)
at Function.Module._load (internal/modules/cjs/loader.js:529:3)
at Function.Module.runMain (internal/modules/cjs/loader.js:741:12)
at startup (internal/bootstrap/node.js:285:19)
at bootstrapNodeJSCore (internal/bootstrap/node.js:739:3)
[nodemon] app crashed - waiting for file changes before starting...