anchor.diff:              | Paused -> pausedEvent.Trigger(x, { queue = this })
               | Resumed -> resumedEvent.Trigger(x, { queue = this })
               | _ -> failwith "Not a queue event!"
  -        }
  -
  -    member internal x.emitNewJobEvent jobId =
  -        async {
  -            newJobEvent.Trigger(x, { jobId = jobId })
           }
   
       member internal x.emitJobEvent (eventType, job:Job<'a>, ?value, ?exn, ?data) =
  
positive.code:     let onPaused = pausedEvent.Publish
      let onResumed = resumedEvent.Publish
      let onNewJob = newJobEvent.Publish
  
      let processJob handler job =
          async {
  
negative.code:     let resumedChannel = _toKey("resumed") |> keyToChannel
      let pausedChannel = _toKey("paused") |> keyToChannel
  
      let completedEvent = new Event<OxenJobEventDelegate<'a>, OxenJobEvent<'a>> ()
      let progressEvent = new Event<OxenJobEventDelegate<'a>, OxenJobEvent<'a>> ()
      let failedEvent = new Event<OxenJobEventDelegate<'a>, OxenJobEvent<'a>> ()
  