https://github.com/Azure/azure-sdk-for-java: This package contains Microsoft Azure Resource Management SDK. A new set of management libraries are now Generally Available. For documentation on how to use the new libraries, please see https://aka.ms/azsdk/java/mgmt
  • Microsoft 
public class com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor implements okhttp3.Interceptor
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor
  super_class: java.lang.Object
{
  private static final java.lang.String LOGGING_HEADER;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "x-ms-logging-context"

  private static final java.util.concurrent.ConcurrentMap<java.lang.String, java.util.concurrent.locks.ReentrantLock> REENTRANT_LOCK_MAP;
    descriptor: Ljava/util/concurrent/ConcurrentMap;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/lang/String;Ljava/util/concurrent/locks/ReentrantLock;>;

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 36
            new java.util.concurrent.ConcurrentHashMap
            dup
            invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
            putstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor this
         0: .line 34
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/microsoft/azure/management/resources/fluentcore/utils/ResourceManagerThrottlingInterceptor;

  public okhttp3.Response intercept(okhttp3.Interceptor$Chain);
    descriptor: (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=12, args_size=2
        start local 0 // com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor this
        start local 1 // okhttp3.Interceptor$Chain chain
         0: .line 41
            aload 1 /* chain */
            invokeinterface okhttp3.Interceptor$Chain.request:()Lokhttp3/Request;
            invokevirtual okhttp3.Request.url:()Lokhttp3/HttpUrl;
            invokevirtual okhttp3.HttpUrl.url:()Ljava/net/URL;
            invokevirtual java.net.URL.getPath:()Ljava/lang/String;
            ldc "subscriptions"
            invokestatic com.microsoft.azure.management.resources.fluentcore.arm.ResourceUtils.extractFromResourceId:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            astore 2 /* subscriptionId */
        start local 2 // java.lang.String subscriptionId
         1: .line 42
            aload 2 /* subscriptionId */
            ifnonnull 3
         2: .line 43
            ldc "global"
            astore 2 /* subscriptionId */
         3: .line 45
      StackMap locals: java.lang.String
      StackMap stack:
            new java.lang.StringBuilder
            dup
            aload 2 /* subscriptionId */
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc "|"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* chain */
            invokeinterface okhttp3.Interceptor$Chain.request:()Lokhttp3/Request;
            invokevirtual okhttp3.Request.method:()Ljava/lang/String;
            getstatic java.util.Locale.ROOT:Ljava/util/Locale;
            invokevirtual java.lang.String.toLowerCase:(Ljava/util/Locale;)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            astore 3 /* subscriptionAndMethod */
        start local 3 // java.lang.String subscriptionAndMethod
         4: .line 46
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            new java.util.concurrent.locks.ReentrantLock
            dup
            invokespecial java.util.concurrent.locks.ReentrantLock.<init>:()V
            invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 48
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            dup
            astore 4
            monitorenter
         6: .line 49
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.util.concurrent.locks.ReentrantLock.isLocked:()Z
            ifeq 8
         7: .line 50
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.lang.Object.wait:()V
         8: .line 48
      StackMap locals: java.lang.String java.util.concurrent.locks.ReentrantLock
      StackMap stack:
            aload 4
            monitorexit
         9: goto 14
      StackMap locals:
      StackMap stack: java.lang.Throwable
        10: aload 4
            monitorexit
        11: athrow
        12: .line 53
      StackMap locals: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor okhttp3.Interceptor$Chain java.lang.String java.lang.String
      StackMap stack: java.lang.InterruptedException
            astore 4 /* e */
        start local 4 // java.lang.InterruptedException e
        13: .line 54
            new java.io.IOException
            dup
            aload 4 /* e */
            invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 4 // java.lang.InterruptedException e
        14: .line 56
      StackMap locals:
      StackMap stack:
            aload 1 /* chain */
            aload 1 /* chain */
            invokeinterface okhttp3.Interceptor$Chain.request:()Lokhttp3/Request;
            invokeinterface okhttp3.Interceptor$Chain.proceed:(Lokhttp3/Request;)Lokhttp3/Response;
            astore 4 /* response */
        start local 4 // okhttp3.Response response
        15: .line 57
            aload 4 /* response */
            invokevirtual okhttp3.Response.code:()I
            sipush 429
            if_icmpeq 17
        16: .line 58
            aload 4 /* response */
            areturn
        17: .line 62
      StackMap locals: okhttp3.Response
      StackMap stack:
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            dup
            astore 5
            monitorenter
        18: .line 63
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.util.concurrent.locks.ReentrantLock.isLocked:()Z
            ifeq 23
        19: .line 64
            aload 4 /* response */
            invokevirtual okhttp3.Response.close:()V
        20: .line 65
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.lang.Object.wait:()V
        21: .line 66
            aload 1 /* chain */
            aload 1 /* chain */
            invokeinterface okhttp3.Interceptor$Chain.request:()Lokhttp3/Request;
            invokeinterface okhttp3.Interceptor$Chain.proceed:(Lokhttp3/Request;)Lokhttp3/Response;
            aload 5
            monitorexit
        22: areturn
        23: .line 68
      StackMap locals: java.util.concurrent.locks.ReentrantLock
      StackMap stack:
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.util.concurrent.locks.ReentrantLock.lock:()V
        24: .line 62
            aload 5
            monitorexit
        25: goto 30
      StackMap locals:
      StackMap stack: java.lang.Throwable
        26: aload 5
            monitorexit
        27: athrow
        28: .line 71
      StackMap locals: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor okhttp3.Interceptor$Chain java.lang.String java.lang.String okhttp3.Response
      StackMap stack: java.lang.InterruptedException
            astore 5 /* e */
        start local 5 // java.lang.InterruptedException e
        29: .line 72
            new java.io.IOException
            dup
            aload 5 /* e */
            invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 5 // java.lang.InterruptedException e
        30: .line 76
      StackMap locals:
      StackMap stack:
            aload 4 /* response */
            ldc "Retry-After"
            invokevirtual okhttp3.Response.header:(Ljava/lang/String;)Ljava/lang/String;
            astore 5 /* retryAfterHeader */
        start local 5 // java.lang.String retryAfterHeader
        31: .line 77
            iconst_0
            istore 6 /* retryAfter */
        start local 6 // int retryAfter
        32: .line 78
            aload 5 /* retryAfterHeader */
            ifnull 41
        33: .line 79
            aconst_null
            astore 7 /* retryWhen */
        start local 7 // org.joda.time.DateTime retryWhen
        34: .line 81
            new com.microsoft.rest.DateTimeRfc1123
            dup
            aload 5 /* retryAfterHeader */
            invokespecial com.microsoft.rest.DateTimeRfc1123.<init>:(Ljava/lang/String;)V
            invokevirtual com.microsoft.rest.DateTimeRfc1123.dateTime:()Lorg/joda/time/DateTime;
            astore 7 /* retryWhen */
        35: .line 82
            goto 37
      StackMap locals: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor okhttp3.Interceptor$Chain java.lang.String java.lang.String okhttp3.Response java.lang.String int org.joda.time.DateTime
      StackMap stack: java.lang.Exception
        36: pop
        37: .line 83
      StackMap locals:
      StackMap stack:
            aload 7 /* retryWhen */
            ifnonnull 40
        38: .line 84
            aload 5 /* retryAfterHeader */
            invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
            istore 6 /* retryAfter */
        39: .line 85
            goto 41
        40: .line 86
      StackMap locals:
      StackMap stack:
            new org.joda.time.Duration
            dup
            aconst_null
            aload 7 /* retryWhen */
            invokespecial org.joda.time.Duration.<init>:(Lorg/joda/time/ReadableInstant;Lorg/joda/time/ReadableInstant;)V
            invokevirtual org.joda.time.Duration.toStandardSeconds:()Lorg/joda/time/Seconds;
            invokevirtual org.joda.time.Seconds.getSeconds:()I
            istore 6 /* retryAfter */
        end local 7 // org.joda.time.DateTime retryWhen
        41: .line 89
      StackMap locals:
      StackMap stack:
            iload 6 /* retryAfter */
            ifgt 51
        42: .line 90
            ldc "try again after '([0-9]*)' minutes"
            iconst_2
            invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;I)Ljava/util/regex/Pattern;
            astore 7 /* pattern */
        start local 7 // java.util.regex.Pattern pattern
        43: .line 91
            aload 7 /* pattern */
            aload 0 /* this */
            aload 4 /* response */
            invokevirtual okhttp3.Response.body:()Lokhttp3/ResponseBody;
            invokevirtual com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.content:(Lokhttp3/ResponseBody;)Ljava/lang/String;
            invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
            astore 8 /* matcher */
        start local 8 // java.util.regex.Matcher matcher
        44: .line 92
            aload 8 /* matcher */
            invokevirtual java.util.regex.Matcher.find:()Z
            ifeq 47
        45: .line 93
            getstatic java.util.concurrent.TimeUnit.MINUTES:Ljava/util/concurrent/TimeUnit;
            aload 8 /* matcher */
            iconst_1
            invokevirtual java.util.regex.Matcher.group:(I)Ljava/lang/String;
            invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
            i2l
            invokevirtual java.util.concurrent.TimeUnit.toSeconds:(J)J
            l2i
            istore 6 /* retryAfter */
        46: .line 94
            goto 51
        47: .line 95
      StackMap locals: java.util.regex.Pattern java.util.regex.Matcher
      StackMap stack:
            ldc "try again after '([0-9]*)' seconds"
            iconst_2
            invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;I)Ljava/util/regex/Pattern;
            astore 7 /* pattern */
        48: .line 96
            aload 7 /* pattern */
            aload 0 /* this */
            aload 4 /* response */
            invokevirtual okhttp3.Response.body:()Lokhttp3/ResponseBody;
            invokevirtual com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.content:(Lokhttp3/ResponseBody;)Ljava/lang/String;
            invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
            astore 8 /* matcher */
        49: .line 97
            aload 8 /* matcher */
            invokevirtual java.util.regex.Matcher.find:()Z
            ifeq 51
        50: .line 98
            aload 8 /* matcher */
            iconst_1
            invokevirtual java.util.regex.Matcher.group:(I)Ljava/lang/String;
            invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
            istore 6 /* retryAfter */
        end local 8 // java.util.regex.Matcher matcher
        end local 7 // java.util.regex.Pattern pattern
        51: .line 102
      StackMap locals:
      StackMap stack:
            iload 6 /* retryAfter */
            ifle 59
        52: .line 103
            aload 1 /* chain */
            invokeinterface okhttp3.Interceptor$Chain.request:()Lokhttp3/Request;
            ldc "x-ms-logging-context"
            invokevirtual okhttp3.Request.header:(Ljava/lang/String;)Ljava/lang/String;
            astore 7 /* context */
        start local 7 // java.lang.String context
        53: .line 104
            aload 7 /* context */
            ifnonnull 55
        54: .line 105
            ldc ""
            astore 7 /* context */
        55: .line 107
      StackMap locals: java.lang.String
      StackMap stack:
            aload 7 /* context */
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/String;)Lorg/slf4j/Logger;
        56: .line 108
            new java.lang.StringBuilder
            dup
            ldc "Azure Resource Manager read/write per hour limit reached. Will retry in: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 6 /* retryAfter */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc " seconds"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
        57: .line 109
            aload 4 /* response */
            invokevirtual okhttp3.Response.close:()V
        58: .line 110
            getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
            iload 6 /* retryAfter */
            i2l
            invokevirtual java.util.concurrent.TimeUnit.toMillis:(J)J
            ldc 100
            ladd
            l2i
            invokestatic com.microsoft.azure.management.resources.fluentcore.utils.SdkContext.sleep:(I)V
        end local 7 // java.lang.String context
        59: .line 112
      StackMap locals:
      StackMap stack:
            aload 1 /* chain */
            aload 1 /* chain */
            invokeinterface okhttp3.Interceptor$Chain.request:()Lokhttp3/Request;
            invokeinterface okhttp3.Interceptor$Chain.proceed:(Lokhttp3/Request;)Lokhttp3/Response;
            astore 10
        60: .line 116
            aload 4 /* response */
            invokevirtual okhttp3.Response.close:()V
        61: .line 117
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            dup
            astore 11
            monitorenter
        62: .line 118
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.util.concurrent.locks.ReentrantLock.unlock:()V
        63: .line 119
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.lang.Object.notifyAll:()V
        64: .line 117
            aload 11
            monitorexit
        65: goto 68
      StackMap locals: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor okhttp3.Interceptor$Chain java.lang.String java.lang.String okhttp3.Response java.lang.String int top top top okhttp3.Response java.util.concurrent.locks.ReentrantLock
      StackMap stack: java.lang.Throwable
        66: aload 11
            monitorexit
        67: athrow
        68: .line 112
      StackMap locals:
      StackMap stack:
            aload 10
            areturn
        end local 6 // int retryAfter
        end local 5 // java.lang.String retryAfterHeader
        69: .line 113
      StackMap locals: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor okhttp3.Interceptor$Chain java.lang.String java.lang.String okhttp3.Response
      StackMap stack: java.lang.Throwable
            astore 5 /* t */
        start local 5 // java.lang.Throwable t
        70: .line 114
            new java.io.IOException
            dup
            aload 5 /* t */
            invokespecial java.io.IOException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 5 // java.lang.Throwable t
        71: .line 115
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 9
        72: .line 116
            aload 4 /* response */
            invokevirtual okhttp3.Response.close:()V
        73: .line 117
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            dup
            astore 11
            monitorenter
        74: .line 118
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.util.concurrent.locks.ReentrantLock.unlock:()V
        75: .line 119
            getstatic com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor.REENTRANT_LOCK_MAP:Ljava/util/concurrent/ConcurrentMap;
            aload 3 /* subscriptionAndMethod */
            invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.concurrent.locks.ReentrantLock
            invokevirtual java.lang.Object.notifyAll:()V
        76: .line 117
            aload 11
            monitorexit
        77: goto 80
      StackMap locals: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor okhttp3.Interceptor$Chain java.lang.String java.lang.String okhttp3.Response top top top top java.lang.Throwable top java.util.concurrent.locks.ReentrantLock
      StackMap stack: java.lang.Throwable
        78: aload 11
            monitorexit
        79: athrow
        80: .line 121
      StackMap locals: com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor okhttp3.Interceptor$Chain java.lang.String java.lang.String okhttp3.Response top top top top java.lang.Throwable
      StackMap stack:
            aload 9
            athrow
        end local 4 // okhttp3.Response response
        end local 3 // java.lang.String subscriptionAndMethod
        end local 2 // java.lang.String subscriptionId
        end local 1 // okhttp3.Interceptor$Chain chain
        end local 0 // com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0   81     0                   this  Lcom/microsoft/azure/management/resources/fluentcore/utils/ResourceManagerThrottlingInterceptor;
            0   81     1                  chain  Lokhttp3/Interceptor$Chain;
            1   81     2         subscriptionId  Ljava/lang/String;
            4   81     3  subscriptionAndMethod  Ljava/lang/String;
           13   14     4                      e  Ljava/lang/InterruptedException;
           15   81     4               response  Lokhttp3/Response;
           29   30     5                      e  Ljava/lang/InterruptedException;
           31   69     5       retryAfterHeader  Ljava/lang/String;
           32   69     6             retryAfter  I
           34   41     7              retryWhen  Lorg/joda/time/DateTime;
           43   51     7                pattern  Ljava/util/regex/Pattern;
           44   51     8                matcher  Ljava/util/regex/Matcher;
           53   59     7                context  Ljava/lang/String;
           70   71     5                      t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           6     9      10  any
          10    11      10  any
           5    12      12  Class java.lang.InterruptedException
          18    22      26  any
          23    25      26  any
          26    27      26  any
          17    22      28  Class java.lang.InterruptedException
          23    28      28  Class java.lang.InterruptedException
          34    35      36  Class java.lang.Exception
          62    65      66  any
          66    67      66  any
          30    60      69  Class java.lang.Throwable
          30    60      71  any
          69    71      71  any
          74    77      78  any
          78    79      78  any
    Exceptions:
      throws java.io.IOException
    MethodParameters:
       Name  Flags
      chain  

  private java.lang.String content(okhttp3.ResponseBody);
    descriptor: (Lokhttp3/ResponseBody;)Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor this
        start local 1 // okhttp3.ResponseBody responseBody
         0: .line 125
            aload 1 /* responseBody */
            ifnonnull 2
         1: .line 126
            aconst_null
            areturn
         2: .line 128
      StackMap locals:
      StackMap stack:
            aload 1 /* responseBody */
            invokevirtual okhttp3.ResponseBody.source:()Lokio/BufferedSource;
            astore 2 /* source */
        start local 2 // okio.BufferedSource source
         3: .line 129
            aload 2 /* source */
            ldc 9223372036854775807
            invokeinterface okio.BufferedSource.request:(J)Z
            pop
         4: .line 130
            aload 2 /* source */
            invokeinterface okio.BufferedSource.buffer:()Lokio/Buffer;
            astore 3 /* buffer */
        start local 3 // okio.Buffer buffer
         5: .line 131
            aload 3 /* buffer */
            invokevirtual okio.Buffer.readUtf8:()Ljava/lang/String;
            areturn
        end local 3 // okio.Buffer buffer
        end local 2 // okio.BufferedSource source
        end local 1 // okhttp3.ResponseBody responseBody
        end local 0 // com.microsoft.azure.management.resources.fluentcore.utils.ResourceManagerThrottlingInterceptor this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    6     0          this  Lcom/microsoft/azure/management/resources/fluentcore/utils/ResourceManagerThrottlingInterceptor;
            0    6     1  responseBody  Lokhttp3/ResponseBody;
            3    6     2        source  Lokio/BufferedSource;
            5    6     3        buffer  Lokio/Buffer;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
              Name  Flags
      responseBody  
}
SourceFile: "ResourceManagerThrottlingInterceptor.java"
InnerClasses:
  public abstract Chain = okhttp3.Interceptor$Chain of okhttp3.Interceptor