queue_outbound.js

var outbound = require('./outbound');
var constants = require('./constants');

exports.hook_queue = function (next, connection) {
    var transaction = connection.transaction;

    outbound.send_email(connection.transaction, function(retval, msg) {
        switch(retval) {
            case constants.ok:
                return next(OK, msg);
                break;
            case constants.deny:
                return next(DENY, msg);
                break;
            default:
                return next(DENYSOFT, msg);
        }
    });
}