Aedes  

Barebone MQTT server that can run on any stream server.

Example

var aedes = require('./aedes')()
var server = require('net').createServer(aedes.handle)
var port = 1883

server.listen(port, function () {
  console.log('server listening on port', port)
})

Todo

• QoS 0 support
• Retain messages support
• QoS 1 support
• QoS 2 support
• clean=false support
• Keep alive support
• Will messages must survive crash
• Authentication
• Mosca events
• Wait a CONNECT packet only for X seconds
• Support a CONNECT packet without a clientId
• Disconnect other clients with the same client.id
• Write docs
• Support counting the number of offline clients and subscriptions
• move the persistence in a separate module
• mongo persistence (external module)
• redis persistence (external module)
• levelup persistence (external module)

License

MIT