2014-09-02 07:08:12 -07:00
|
|
|
var mdb = require('../lib/MessageDb').default();
|
|
|
|
var logger = require('../lib/logger').logger;
|
|
|
|
var preconditions = require('preconditions').singleton();
|
|
|
|
var microtime = require('microtime');
|
2014-09-02 07:44:07 -07:00
|
|
|
var cron = require('cron');
|
|
|
|
var CronJob = cron.CronJob;
|
2014-09-02 07:08:12 -07:00
|
|
|
|
|
|
|
|
|
|
|
module.exports.init = function(config) {
|
2014-09-02 07:44:07 -07:00
|
|
|
var cronTime = config.cronTime || '0 * * * *';
|
|
|
|
logger.info('Using monitor plugin with cronTime ' + cronTime);
|
|
|
|
var onTick = function() {
|
|
|
|
mdb.getAll(function(err, messages) {
|
|
|
|
if (err) logger.error(err);
|
|
|
|
else {
|
|
|
|
logger.info('Message db size = ' + messages.length);
|
|
|
|
}
|
|
|
|
});
|
|
|
|
};
|
|
|
|
var job = new CronJob({
|
|
|
|
cronTime: cronTime,
|
|
|
|
onTick: onTick
|
|
|
|
});
|
|
|
|
onTick();
|
|
|
|
job.start();
|
2014-09-02 07:08:12 -07:00
|
|
|
};
|