anchor.diff:      let StreamOffsetPropertyName = "StreamOffset"
       let SubscriptionAutoDeleteInterval = TimeSpan.MaxValue 
   
  +/// Info stored in BrokeredMessage.
  +type internal JobLeaseTokenInfo =
  +    {
  +        ConfigurationId : ConfigurationId
  +        JobId : string
  +        MessageLockId : Guid
  +        ParentJobId : string
  +        Offset : int64 option 
  +        TargetWorker : string option
  +        DeliveryCount : int
  +        DequeueTime : DateTimeOffset
  +    }
  +
   [<Sealed; AbstractClass>]
  -type JobLeaseMonitor private () = 
  +type internal JobLeaseMonitor private () = 
       
       static member Start(message : BrokeredMessage) = 
           Async.StartChild(let rec renewLoop() = 
  
positive.code:                              }
                           renewLoop())
      
      static member Complete(token : JobLeaseToken) : Async<unit> = 
          async { 
              let config = token.ConfigurationId
              match token.TargetWorker with
  
negative.code: ﻿namespace MBrace.Azure.Runtime
  
  open System
  open Microsoft.ServiceBus.Messaging
  open MBrace.Azure.Runtime
  open MBrace.Azure.Runtime.Utilities
  open MBrace.Azure
  open MBrace.Core.Internals
  open System.IO
  open MBrace.Azure.Runtime.Primitives
  open MBrace.Runtime
  open System.Runtime.Serialization
  
  [<AutoOpenAttribute>]
  module private Helpers = 
  