index.js
function add(message) {
        if (!message.order || // no keep order needed
                message.inProcess) {// or already in process
            return false; // should continue
        }

        var queue = this.getQueue(message.context);
        queue.unshift(message); // FIFO
        message.pointId = this.pipe._id;
        var moreInQueue = queue.length > 1;
        message.inProcess = !moreInQueue;

        return moreInQueue;
    }
function add(message) {
        if (!message.order || // no keep order needed
                message.inProcess) {// or already in process
            return false; // should continue
        }

        var queue = this.getQueue(message.context);
        queue.unshift(message); // FIFO
        message.pointId = this.pipe._id;
        var moreInQueue = queue.length > 1;
        message.inProcess = !moreInQueue;

        return moreInQueue;
    }
function add ( message ) { if ( ! message . order || // no keep order needed message . inProcess ) { // or already in process return false ; // should continue } var queue = this . getQueue ( message . context ) ; queue . unshift ( message ) ; // FIFO message . pointId = this . pipe . _id ; var moreInQueue = queue . length > 1 ; message . inProcess = ! moreInQueue ; return moreInQueue ; }
return true, if message prcessing should be paused
return true if message prcessing should be paused