anchor.diff:              | Paused -> pausedEvent.Trigger({ queue = this });
               | Resumed -> resumedEvent.Trigger({ queue = this });
               | _ -> failwith "Not a queue event!"
  +        }
  +
  +    member internal x.emitNewJobEvent jobId =
  +        async {
  +            newJobEvent.Trigger({ jobId = jobId });
           }
   
       member internal x.emitJobEvent (eventType, job:Job<'a>, ?value, ?exn, ?data) = 
  
positive.code:                 channel,
                  (fun c v -> 
                      async {
                          let! job = Job.fromId(this, fromValueI64(v))
                          return! this.emitJobEvent(NewJob, job)
                      } |> Async.RunSynchronously))
      
      do logger.Info "subscribed to %A" channel
  
negative.code:         Completed = completedEvent.Publish
          Progress = progressEvent.Publish
          Failed = failedEvent.Publish
      }
  
      //Internals
  