anchor.diff:                      } |> Async.RunSynchronously))
   
       do sub.Subscribe(_toKey("paused") |> keyToChannel,
  -        (fun c v ->
  +        (fun _ v ->
               do
                   match v |> string with
                   | "paused" -> this.emitQueueEvent(Paused) |> Async.RunSynchronously
  
positive.code:     let processJob handler job =
          async {
              processing <- true
              use lr = new LockRenewer<'a>(job, token)
              try
                  logger.Info "running handler on job %i queue %s" job.jobId name
                  do! handler job
  
negative.code:     Empty: IEvent<OxenQueueEventDelegate<'a>, OxenQueueEvent<'a>>
      NewJob: IEvent<OxenNewJobEventDelegate, OxenNewJobEvent>
  }
  and EventAwaiterMessage<'a> =
      | Event of OxenJobEvent<'a>
      | WaitFor of (Job<'a> -> bool) * AsyncReplyChannel<Job<'a>>
  
  /// [omit]
  and LockRenewer<'a> (job:Job<'a>, token:Guid) =
      static let logger = LogManager.getLogger()
  