var mosca = require('mosca')
|
|
var moscaSettings = {
|
port: 1883, //mosca (mqtt) port
|
// backend: pubsubsettings //pubsubsettings is the object we created above
|
|
};
|
|
var server = new mosca.Server(moscaSettings); //here we start mosca
|
server.on('ready', function setup() {
|
console.log('Mosca server is up and running')
|
});
|
|
server.on('published', function(packet, client) {
|
// console.log('Published', packet);
|
// console.log('Client', client);
|
});
|
// fired when a client connects
|
server.on('clientConnected', function(client) {
|
console.log('Client Connected:', client);
|
});
|
|
// fired when a client disconnects
|
server.on('clientDisconnected', function(client) {
|
// console.log('Client Disconnected:', client.id);
|
});
|
|
|
|
