anchor.diff:      static member MaxLockDuration = WorkerManager.MaxHeartbeatTimespan // 5 minutes, max value
       static member MaxTTL = TimeSpan.MaxValue
       static member ServerWaitTime = TimeSpan.FromMilliseconds(50.)
  -    static member AffinityPropertyName = "worker"
  -    static member ParentTaskIdPropertyName = "parentId"
  -    static member StreamOffsetPropertyName = "offset"
  +    static member AffinityProperty = "worker"
  +    static member ParentTaskIdProperty = "parentId"
  +    static member StreamOffsetProperty = "offset"
  +    static member JobIdProperty = "uuid"
       static member SubscriptionAutoDeleteInterval = TimeSpan.MaxValue 
   
   /// Info stored in BrokeredMessage.
  
positive.code: 
      do init ()
  
      member this.Id              = info.JobId
      member this.ConfigurationId = info.ConfigurationId
      member this.TargetWorker    = info.TargetWorker
      member this.MessageLockId   = info.MessageLockId
      member this.DeliveryCount   = info.DeliveryCount
      member this.ParentJobId     = info.ParentJobId
      member this.DequeueTime     = info.DequeueTime
  
      interface ICloudJobLeaseToken with
          member this.DeclareCompleted() : Async<unit> = 
  
negative.code:             sd.DefaultMessageTimeToLive <- Settings.MaxTTL
              sd.LockDuration <- Settings.MaxLockDuration
              sd.AutoDeleteOnIdle <- Settings.SubscriptionAutoDeleteInterval
              let filter = new SqlFilter(sprintf "%s = '%s'" Settings.AffinityProperty affinity)
              ns.CreateSubscription(sd, filter) |> ignore
  
      let sub = cp.SubscriptionClient(config.RuntimeTopic, workerId.Id)
  