 allMessages = Rx.Observable
 .interval(500)
 .filter (tick) ->
-  stats.applyBackpressureAtTick(tick)
+  not stats.applyBackpressureAtTick(tick)
 .flatMap ->
   messageService.getMessages()
 .map (msg) ->

    @messagesOut = @messagesOut + 1

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

class BatchMessageService
  constructor: ->

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

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

