anchor.diff:              logger.Info "adding job %i to the queue %s" jobId name
               let! job = Job<'a>.create (this, jobId, data, opts) 
               let key = this.toKey "wait"
  -            let! res = 
  -                Async.AwaitTask <|
  +            let multi = this.client().CreateTransaction();
  +
  +            let res = 
                   match opts with
  -                | None -> this.client().ListLeftPushAsync (key, toValueI64 jobId) 
  +                | None -> multi.ListLeftPushAsync (key, toValueI64 jobId) 
                   | Some opts -> 
                       if opts.ContainsKey "lifo" && bool.Parse (opts.Item "lifo") 
  -                    then this.client().ListRightPushAsync (key, toValueI64 jobId) 
  -                    else this.client().ListLeftPushAsync (key, toValueI64 jobId) 
  -
  -            let! result = this.publish job.jobId
  +                    then multi.ListRightPushAsync (key, toValueI64 jobId) 
  +                    else multi.ListLeftPushAsync (key, toValueI64 jobId) 
  +           
  +            let result =  multi.PublishAsync (channel, toValueI64 jobId)
  +           
  +            do! multi.ExecuteAsync() |> Async.AwaitTask |> Async.Ignore
                          
  -            if result < 1L then failwith "must have atleast one subscriber, me"
  +            if result.Result < 1L then failwith "must have atleast one subscriber, me"
   
               return job
           }
  
positive.code:         let jsData = JsonConvert.SerializeObject (this.data)
          let jsOpts = JsonConvert.SerializeObject (this.opts)
          [|
              HashEntry(toValueStr "id", toValueI64 this.jobId)
              HashEntry(toValueStr "data", toValueStr jsData)
              HashEntry(toValueStr "opts", toValueStr jsOpts)
              HashEntry(toValueStr "progress", toValueI32 this._progress)
  
negative.code: 
  open System
  open System.IO
  open System.Collections.Generic
  open System.Threading.Tasks
  open System.Threading
  open StackExchange.Redis
  