Awesome
MQTT.js NeDB Store
NeDB Store for in-flight MQTT.js packets. Thanks to nedb.
Usage
'use strict';
var mqtt = require('mqtt'),
NeDBStore = require('mqtt-nedb-store'),
manager = NeDBStore('path/to/db');
var client = mqtt.connect({
port: 8883,
incomingStore: manager.incoming,
outgoingStore: manager.outgoing
});
//// or
// var client = mqtt.connect('mqtt://test.mosca.io', {
// port: 8883,
// incomingStore: manager.incoming,
// outgoingStore: manager.outgoing
//});
client.on('connect', function() {
console.log('connected');
client.publish('hello', 'world', {qos: 1}, function() {
console.log('published');
client.end();
});
});
Automatic compaction
NeDB datastores are compacted by default only when opened. NeDB's automatic periodic compaction can be activated with NeDB constructor options:
manager = NeDBStore('path/to/db', { outgoing: { autocompactionInterval: 60 } });
License
MIT