public class org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher<K, V> extends org.ehcache.impl.internal.events.AbstractStoreEventDispatcher<K, V>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher
  super_class: org.ehcache.impl.internal.events.AbstractStoreEventDispatcher
{
  private final java.lang.ThreadLocal<org.ehcache.core.events.StoreEventSink<K, V>> tlEventSink;
    descriptor: Ljava/lang/ThreadLocal;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/lang/ThreadLocal<Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;>;

  private final java.lang.ThreadLocal<java.lang.Integer> usageDepth;
    descriptor: Ljava/lang/ThreadLocal;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/lang/ThreadLocal<Ljava/lang/Integer;>;

  public void <init>(int);
    descriptor: (I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
        start local 1 // int dispatcherConcurrency
         0: .line 30
            aload 0 /* this */
            iload 1 /* dispatcherConcurrency */
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.<init>:(I)V
         1: .line 26
            aload 0 /* this */
            new java.lang.ThreadLocal
            dup
            invokespecial java.lang.ThreadLocal.<init>:()V
            putfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.tlEventSink:Ljava/lang/ThreadLocal;
         2: .line 27
            aload 0 /* this */
            new java.lang.ThreadLocal
            dup
            invokespecial java.lang.ThreadLocal.<init>:()V
            putfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
         3: .line 31
            return
        end local 1 // int dispatcherConcurrency
        end local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0    4     0                   this  Lorg/ehcache/impl/internal/events/ThreadLocalStoreEventDispatcher<TK;TV;>;
            0    4     1  dispatcherConcurrency  I
    MethodParameters:
                       Name  Flags
      dispatcherConcurrency  

  public org.ehcache.core.events.StoreEventSink<K, V> eventSink();
    descriptor: ()Lorg/ehcache/core/events/StoreEventSink;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=2, args_size=1
        start local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
         0: .line 35
            aload 0 /* this */
            invokevirtual org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.getListeners:()Ljava/util/Set;
            invokeinterface java.util.Set.isEmpty:()Z
            ifeq 3
         1: .line 37
            getstatic org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.NO_OP_EVENT_SINK:Lorg/ehcache/core/events/StoreEventSink;
            astore 1 /* noOpEventSink */
        start local 1 // org.ehcache.core.events.StoreEventSink noOpEventSink
         2: .line 38
            aload 1 /* noOpEventSink */
            areturn
        end local 1 // org.ehcache.core.events.StoreEventSink noOpEventSink
         3: .line 40
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.tlEventSink:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.get:()Ljava/lang/Object;
            checkcast org.ehcache.core.events.StoreEventSink
            astore 1 /* eventSink */
        start local 1 // org.ehcache.core.events.StoreEventSink eventSink
         4: .line 41
            aload 1 /* eventSink */
            ifnonnull 9
         5: .line 42
            new org.ehcache.impl.internal.events.FudgingInvocationScopedEventSink
            dup
            aload 0 /* this */
            invokevirtual org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.getFilters:()Ljava/util/Set;
            aload 0 /* this */
            invokevirtual org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.isEventOrdering:()Z
            aload 0 /* this */
            invokevirtual org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.getOrderedQueues:()[Ljava/util/concurrent/BlockingQueue;
            aload 0 /* this */
            invokevirtual org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.getListeners:()Ljava/util/Set;
            invokespecial org.ehcache.impl.internal.events.FudgingInvocationScopedEventSink.<init>:(Ljava/util/Set;Z[Ljava/util/concurrent/BlockingQueue;Ljava/util/Set;)V
            astore 1 /* eventSink */
         6: .line 43
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.tlEventSink:Ljava/lang/ThreadLocal;
            aload 1 /* eventSink */
            invokevirtual java.lang.ThreadLocal.set:(Ljava/lang/Object;)V
         7: .line 44
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            iconst_0
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual java.lang.ThreadLocal.set:(Ljava/lang/Object;)V
         8: .line 45
            goto 10
         9: .line 46
      StackMap locals: org.ehcache.core.events.StoreEventSink
      StackMap stack:
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.get:()Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            iconst_1
            iadd
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual java.lang.ThreadLocal.set:(Ljava/lang/Object;)V
        10: .line 48
      StackMap locals:
      StackMap stack:
            aload 1 /* eventSink */
            areturn
        end local 1 // org.ehcache.core.events.StoreEventSink eventSink
        end local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   11     0           this  Lorg/ehcache/impl/internal/events/ThreadLocalStoreEventDispatcher<TK;TV;>;
            2    3     1  noOpEventSink  Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;
            4   11     1      eventSink  Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;
    Signature: ()Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;

  public void releaseEventSink(org.ehcache.core.events.StoreEventSink<K, V>);
    descriptor: (Lorg/ehcache/core/events/StoreEventSink;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=2
        start local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
        start local 1 // org.ehcache.core.events.StoreEventSink eventSink
         0: .line 54
            aload 1 /* eventSink */
            getstatic org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.NO_OP_EVENT_SINK:Lorg/ehcache/core/events/StoreEventSink;
            if_acmpeq 13
         1: .line 55
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.get:()Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            istore 2 /* depthValue */
        start local 2 // int depthValue
         2: .line 56
            iload 2 /* depthValue */
            ifne 12
         3: .line 58
            aload 0 /* this */
            aload 1 /* eventSink */
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.releaseEventSink:(Lorg/ehcache/core/events/StoreEventSink;)V
         4: .line 59
            goto 9
      StackMap locals: org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher org.ehcache.core.events.StoreEventSink int
      StackMap stack: java.lang.Throwable
         5: astore 3
         6: .line 60
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.tlEventSink:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
         7: .line 61
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
         8: .line 62
            aload 3
            athrow
         9: .line 60
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.tlEventSink:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
        10: .line 61
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
        11: .line 63
            goto 13
        12: .line 64
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            iload 2 /* depthValue */
            iconst_1
            isub
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual java.lang.ThreadLocal.set:(Ljava/lang/Object;)V
        end local 2 // int depthValue
        13: .line 67
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.ehcache.core.events.StoreEventSink eventSink
        end local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   14     0        this  Lorg/ehcache/impl/internal/events/ThreadLocalStoreEventDispatcher<TK;TV;>;
            0   14     1   eventSink  Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;
            2   13     2  depthValue  I
      Exception table:
        from    to  target  type
           3     5       5  any
    Signature: (Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;)V
    MethodParameters:
           Name  Flags
      eventSink  

  public void releaseEventSinkAfterFailure(org.ehcache.core.events.StoreEventSink<K, V>, java.lang.Throwable);
    descriptor: (Lorg/ehcache/core/events/StoreEventSink;Ljava/lang/Throwable;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=3
        start local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
        start local 1 // org.ehcache.core.events.StoreEventSink eventSink
        start local 2 // java.lang.Throwable throwable
         0: .line 71
            aload 1 /* eventSink */
            getstatic org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.NO_OP_EVENT_SINK:Lorg/ehcache/core/events/StoreEventSink;
            if_acmpeq 13
         1: .line 72
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.get:()Ljava/lang/Object;
            checkcast java.lang.Integer
            invokevirtual java.lang.Integer.intValue:()I
            istore 3 /* depthValue */
        start local 3 // int depthValue
         2: .line 73
            iload 3 /* depthValue */
            ifne 12
         3: .line 75
            aload 0 /* this */
            aload 1 /* eventSink */
            aload 2 /* throwable */
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.releaseEventSinkAfterFailure:(Lorg/ehcache/core/events/StoreEventSink;Ljava/lang/Throwable;)V
         4: .line 76
            goto 9
      StackMap locals: org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher org.ehcache.core.events.StoreEventSink java.lang.Throwable int
      StackMap stack: java.lang.Throwable
         5: astore 4
         6: .line 77
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.tlEventSink:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
         7: .line 78
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
         8: .line 79
            aload 4
            athrow
         9: .line 77
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.tlEventSink:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
        10: .line 78
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            invokevirtual java.lang.ThreadLocal.remove:()V
        11: .line 80
            goto 13
        12: .line 81
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher.usageDepth:Ljava/lang/ThreadLocal;
            iload 3 /* depthValue */
            iconst_1
            isub
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual java.lang.ThreadLocal.set:(Ljava/lang/Object;)V
        end local 3 // int depthValue
        13: .line 84
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Throwable throwable
        end local 1 // org.ehcache.core.events.StoreEventSink eventSink
        end local 0 // org.ehcache.impl.internal.events.ThreadLocalStoreEventDispatcher this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   14     0        this  Lorg/ehcache/impl/internal/events/ThreadLocalStoreEventDispatcher<TK;TV;>;
            0   14     1   eventSink  Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;
            0   14     2   throwable  Ljava/lang/Throwable;
            2   13     3  depthValue  I
      Exception table:
        from    to  target  type
           3     5       5  any
    Signature: (Lorg/ehcache/core/events/StoreEventSink<TK;TV;>;Ljava/lang/Throwable;)V
    MethodParameters:
           Name  Flags
      eventSink  
      throwable  

  public void reset(org.ehcache.core.events.StoreEventSink);
    descriptor: (Lorg/ehcache/core/events/StoreEventSink;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.reset:(Lorg/ehcache/core/events/StoreEventSink;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void addEventListener(org.ehcache.core.spi.store.events.StoreEventListener);
    descriptor: (Lorg/ehcache/core/spi/store/events/StoreEventListener;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.addEventListener:(Lorg/ehcache/core/spi/store/events/StoreEventListener;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void setEventOrdering(boolean);
    descriptor: (Z)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.setEventOrdering:(Z)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void addEventFilter(org.ehcache.core.spi.store.events.StoreEventFilter);
    descriptor: (Lorg/ehcache/core/spi/store/events/StoreEventFilter;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.addEventFilter:(Lorg/ehcache/core/spi/store/events/StoreEventFilter;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void removeEventListener(org.ehcache.core.spi.store.events.StoreEventListener);
    descriptor: (Lorg/ehcache/core/spi/store/events/StoreEventListener;)V
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.removeEventListener:(Lorg/ehcache/core/spi/store/events/StoreEventListener;)V
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public boolean isEventOrdering();
    descriptor: ()Z
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokespecial org.ehcache.impl.internal.events.AbstractStoreEventDispatcher.isEventOrdering:()Z
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Lorg/ehcache/impl/internal/events/AbstractStoreEventDispatcher<TK;TV;>;
SourceFile: "ThreadLocalStoreEventDispatcher.java"