42 lines
955 B
JavaScript
42 lines
955 B
JavaScript
var mosca = require('mosca');
|
|
|
|
var ascoltatore = {
|
|
//using ascoltatore
|
|
type: 'mongo',
|
|
url: 'mongodb://localhost:27017/mqtt',
|
|
pubsubCollection: 'ascoltatori',
|
|
mongo: {}
|
|
};
|
|
|
|
var moscaSettings = {
|
|
port: 1883,
|
|
backend: ascoltatore,
|
|
persistence: {
|
|
factory: mosca.persistence.Mongo,
|
|
url: 'mongodb://localhost:27017/mqtt'
|
|
}
|
|
};
|
|
|
|
try {
|
|
var server = new mosca.Server(moscaSettings);
|
|
server.on('ready', setup);
|
|
server.on('error', function(e){
|
|
console.error('e',e);
|
|
});
|
|
|
|
server.on('clientConnected', function (client) {
|
|
console.log('client connected', client.id);
|
|
});
|
|
|
|
// fired when a message is received
|
|
server.on('published', function (packet, client) {
|
|
console.log('Published', packet.payload);
|
|
});
|
|
|
|
// fired when the mqtt server is ready
|
|
function setup() {
|
|
console.log('Mosca server is up and running')
|
|
}
|
|
}catch(e){
|
|
console.error(e);
|
|
} |