anchor.diff:      let processJob handler job =
           async {
               processing <- true
  -            use lr = new LockRenewer<'a>(job, token)
  +            use _ = new LockRenewer<'a>(job, token)
               try
                   logger.Info "running handler on job %i queue %s" job.jobId name
                   do! handler job
  
positive.code: 
              return! jobs |> Seq.map stalledJobsHandler |> Async.Parallel |> Async.Ignore
          }
  
      interface IOxenQueue<'a> with
          member this.Add (data) =
  
negative.code:         Failed = onFailed
          NewJob = onNewJob
      }
  
      /// wait for a specfic job event to happen
      member x.jobAwaiter eventType predicate timeout =
          async {
              let agent = MailboxProcessor<EventAwaiterMessage<'a>>.Start(awaitJobAgent)
  
              match eventType with 
              | Completed -> this.on.Completed.Add(fun e -> agent.Post (Event e))
              | Failed -> this.on.Failed.Add(fun e -> agent.Post(Event e))
              | Progress -> this.on.Progress.Add(fun e -> agent.Post(Event e))
              | _ -> failwith "Not a job event!"
              
              return! agent.PostAndAsyncReply  ((fun channel -> WaitFor (predicate, channel)), timeout)
          }
  
      //Internals
      member internal x.toKey kind = _toKey kind
  