A simple server using mors

barebone_mors.js

var mors = require('mors'),
mosca = require('mosca'),
app = mors();

app.all('*', function (req, res, next) {
  res.topic(req.topic).publish(req.payload);
});

var ascoltatore = {
  //using ascoltatore
  type: 'mongo',        
  url: 'mongodb://localhost:27017/mqtt',
  pubsubCollection: 'ascoltatori',
  mongo: {}
};

var moscaSettings = {
  port: 3000,
  backend: ascoltatore,
  persistence: {
    factory: mosca.persistence.Mongo,
    url: 'mongodb://localhost:27017/mqtt'
  }
};


app.listen(moscaSettings, function (err, server) {
  console.log('Mors/Mosca server started on ' + server.opts.port);
  console.log('================================');
});