var mosca = require('mosca'); var ascoltatore = { //using ascoltatore type: 'mongo', url: 'mongodb://localhost:27017/mqtt', pubsubCollection: 'ascoltatori', mongo: {} }; var settings = { port: 1883, backend: ascoltatore }; var server = new mosca.Server(settings); server.on('clientConnected', function(client) { console.log('client connected', client.id); }); // fired when a message is received serv