   lockedMessage: (msg) ->
     @lockedMessages = @lockedMessages + 1
 
-
   unlockedMessage: (msg) ->
     @lockedMessages = @lockedMessages + 1
 

    @messagesOut = @messagesOut + 1

  failedLock: (msg) ->
    @lockedFailedMessages = @lockedFailedMessages + 1

class BatchMessageService
  constructor: ->


Rx = require 'rx'
Q = require 'q'
{_} = require 'underscore'
express = require 'express'

messageProcessors = [((m)-> Q(m)), ((m)-> Q(m)), ((m)-> Q(m))]
