http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-ignite: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class io.vertx.spi.cluster.ignite.IgniteClusterManager implements io.vertx.core.spi.cluster.ClusterManager
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.spi.cluster.ignite.IgniteClusterManager
  super_class: java.lang.Object
{
  private static final io.vertx.core.logging.Logger log;
    descriptor: Lio/vertx/core/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final java.lang.String DEFAULT_CONFIG_FILE;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "default-ignite.xml"

  private static final java.lang.String CONFIG_FILE;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "ignite.xml"

  public static final java.lang.String VERTX_CACHE_TEMPLATE_NAME;
    descriptor: Ljava/lang/String;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: "*"

  private static final java.lang.String VERTX_NODE_PREFIX;
    descriptor: Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: "vertx.ignite.node."

  private static final javax.cache.expiry.ExpiryPolicy DEFAULT_EXPIRY_POLICY;
    descriptor: Ljavax/cache/expiry/ExpiryPolicy;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.util.Queue<java.lang.String> pendingLocks;
    descriptor: Ljava/util/Queue;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Queue<Ljava/lang/String;>;

  private io.vertx.core.Vertx vertx;
    descriptor: Lio/vertx/core/Vertx;
    flags: (0x0002) ACC_PRIVATE

  private org.apache.ignite.configuration.IgniteConfiguration cfg;
    descriptor: Lorg/apache/ignite/configuration/IgniteConfiguration;
    flags: (0x0002) ACC_PRIVATE

  private org.apache.ignite.Ignite ignite;
    descriptor: Lorg/apache/ignite/Ignite;
    flags: (0x0002) ACC_PRIVATE

  private boolean customIgnite;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private java.lang.String nodeID;
    descriptor: Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE

  private io.vertx.core.spi.cluster.NodeListener nodeListener;
    descriptor: Lio/vertx/core/spi/cluster/NodeListener;
    flags: (0x0002) ACC_PRIVATE

  private org.apache.ignite.lang.IgnitePredicate<org.apache.ignite.events.Event> eventListener;
    descriptor: Lorg/apache/ignite/lang/IgnitePredicate;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lorg/apache/ignite/lang/IgnitePredicate<Lorg/apache/ignite/events/Event;>;

  private volatile boolean active;
    descriptor: Z
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private final java.lang.Object monitor;
    descriptor: Ljava/lang/Object;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private org.apache.ignite.configuration.CollectionConfiguration collectionCfg;
    descriptor: Lorg/apache/ignite/configuration/CollectionConfiguration;
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 77
            ldc Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
            putstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/logging/Logger;
         1: .line 90
            new io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy
            dup
            invokespecial io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy.<init>:()V
            putstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.DEFAULT_EXPIRY_POLICY:Ljavax/cache/expiry/ExpiryPolicy;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
         0: .line 114
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 92
            aload 0 /* this */
            new java.util.concurrent.ConcurrentLinkedQueue
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
         2: .line 100
            aload 0 /* this */
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeID:Ljava/lang/String;
         3: .line 106
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
         4: .line 115
            ldc "IGNITE_NO_SHUTDOWN_HOOK"
            ldc "true"
            invokestatic java.lang.System.setProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            pop
         5: .line 116
            return
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;

  public void <init>(org.apache.ignite.configuration.IgniteConfiguration);
    descriptor: (Lorg/apache/ignite/configuration/IgniteConfiguration;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // org.apache.ignite.configuration.IgniteConfiguration cfg
         0: .line 125
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 92
            aload 0 /* this */
            new java.util.concurrent.ConcurrentLinkedQueue
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
         2: .line 100
            aload 0 /* this */
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeID:Ljava/lang/String;
         3: .line 106
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
         4: .line 126
            aload 0 /* this */
            aload 1 /* cfg */
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
         5: .line 127
            aload 0 /* this */
            aload 1 /* cfg */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.setNodeID:(Lorg/apache/ignite/configuration/IgniteConfiguration;)V
         6: .line 128
            return
        end local 1 // org.apache.ignite.configuration.IgniteConfiguration cfg
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    7     1   cfg  Lorg/apache/ignite/configuration/IgniteConfiguration;
    MethodParameters:
      Name  Flags
      cfg   

  public void <init>(java.net.URL);
    descriptor: (Ljava/net/URL;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.net.URL configFile
         0: .line 137
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 92
            aload 0 /* this */
            new java.util.concurrent.ConcurrentLinkedQueue
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
         2: .line 100
            aload 0 /* this */
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeID:Ljava/lang/String;
         3: .line 106
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
         4: .line 138
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* configFile */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.loadConfiguration:(Ljava/net/URL;)Lorg/apache/ignite/configuration/IgniteConfiguration;
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
         5: .line 139
            return
        end local 1 // java.net.URL configFile
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    6     1  configFile  Ljava/net/URL;
    MethodParameters:
            Name  Flags
      configFile  

  public void <init>(org.apache.ignite.Ignite);
    descriptor: (Lorg/apache/ignite/Ignite;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // org.apache.ignite.Ignite ignite
         0: .line 146
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 92
            aload 0 /* this */
            new java.util.concurrent.ConcurrentLinkedQueue
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
         2: .line 100
            aload 0 /* this */
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeID:Ljava/lang/String;
         3: .line 106
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
         4: .line 147
            aload 1 /* ignite */
            ldc "Ignite instance can't be null."
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         5: .line 148
            aload 0 /* this */
            aload 1 /* ignite */
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
         6: .line 149
            aload 0 /* this */
            iconst_1
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.customIgnite:Z
         7: .line 150
            return
        end local 1 // org.apache.ignite.Ignite ignite
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    8     1  ignite  Lorg/apache/ignite/Ignite;
    MethodParameters:
        Name  Flags
      ignite  

  public org.apache.ignite.Ignite getIgniteInstance();
    descriptor: ()Lorg/apache/ignite/Ignite;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
         0: .line 158
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            areturn
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;

  public void setVertx(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 163
            aload 0 /* this */
            aload 1 /* vertx */
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
         1: .line 164
            return
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    2     1  vertx  Lio/vertx/core/Vertx;
    MethodParameters:
       Name  Flags
      vertx  

  public void nodeListener(io.vertx.core.spi.cluster.NodeListener);
    descriptor: (Lio/vertx/core/spi/cluster/NodeListener;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // io.vertx.core.spi.cluster.NodeListener nodeListener
         0: .line 168
            aload 0 /* this */
            aload 1 /* nodeListener */
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
         1: .line 169
            return
        end local 1 // io.vertx.core.spi.cluster.NodeListener nodeListener
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    2     0          this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    2     1  nodeListener  Lio/vertx/core/spi/cluster/NodeListener;
    MethodParameters:
              Name  Flags
      nodeListener  

  public <K, V> void getAsyncMultiMap(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.spi.cluster.AsyncMultiMap<K, V>>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String name
        start local 2 // io.vertx.core.Handler handler
         0: .line 173
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
         1: .line 174
            aload 0 /* this */
            aload 1 /* name */
            invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$0(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
            aload 2 /* handler */
         2: .line 173
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
         3: .line 176
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    4     1     name  Ljava/lang/String;
            0    4     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/spi/cluster/AsyncMultiMap<TK;TV;>;>;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/spi/cluster/AsyncMultiMap<TK;TV;>;>;>;)V
    MethodParameters:
         Name  Flags
      name     
      handler  

  public <K, V> void getAsyncMap(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.AsyncMap<K, V>>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String name
        start local 2 // io.vertx.core.Handler handler
         0: .line 180
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
         1: .line 181
            aload 0 /* this */
            aload 1 /* name */
            invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$1(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
            aload 2 /* handler */
         2: .line 180
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
         3: .line 183
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    4     1     name  Ljava/lang/String;
            0    4     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;>;)V
    MethodParameters:
         Name  Flags
      name     
      handler  

  public <K, V> java.util.Map<K, V> getSyncMap(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/util/Map;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String name
         0: .line 187
            new io.vertx.spi.cluster.ignite.impl.MapImpl
            dup
            aload 0 /* this */
            aload 1 /* name */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
            invokespecial io.vertx.spi.cluster.ignite.impl.MapImpl.<init>:(Lorg/apache/ignite/IgniteCache;)V
            areturn
        end local 1 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    1     1  name  Ljava/lang/String;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;)Ljava/util/Map<TK;TV;>;
    MethodParameters:
      Name  Flags
      name  

  public void getLockWithTimeout(java.lang.String, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Lock>>);
    descriptor: (Ljava/lang/String;JLio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String name
        start local 2 // long timeout
        start local 4 // io.vertx.core.Handler handler
         0: .line 192
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            aload 1 /* name */
            lload 2 /* timeout */
            invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;J)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$2(Ljava/lang/String;JLio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
         1: .line 224
            iconst_0
            aload 4 /* handler */
         2: .line 192
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
         3: .line 225
            return
        end local 4 // io.vertx.core.Handler handler
        end local 2 // long timeout
        end local 1 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    4     1     name  Ljava/lang/String;
            0    4     2  timeout  J
            0    4     4  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Lock;>;>;
    Signature: (Ljava/lang/String;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Lock;>;>;)V
    MethodParameters:
         Name  Flags
      name     
      timeout  
      handler  

  public void getCounter(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.shareddata.Counter>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String name
        start local 2 // io.vertx.core.Handler handler
         0: .line 229
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            aload 1 /* name */
            invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$3(Ljava/lang/String;Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
            aload 2 /* handler */
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
         1: .line 230
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    2     1     name  Ljava/lang/String;
            0    2     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Counter;>;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/shareddata/Counter;>;>;)V
    MethodParameters:
         Name  Flags
      name     
      handler  

  public java.lang.String getNodeID();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
         0: .line 234
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeID:Ljava/lang/String;
            areturn
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;

  public java.util.List<java.lang.String> getNodes();
    descriptor: ()Ljava/util/List;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
         0: .line 239
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            invokeinterface org.apache.ignite.Ignite.cluster:()Lorg/apache/ignite/IgniteCluster;
            invokeinterface org.apache.ignite.IgniteCluster.nodes:()Ljava/util/Collection;
            invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
         1: .line 240
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.nodeId(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String; (6)
                  (Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.List
         2: .line 239
            areturn
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
    Signature: ()Ljava/util/List<Ljava/lang/String;>;

  public void join(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // io.vertx.core.Handler handler
         0: .line 245
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
            dup
            astore 2
            monitorenter
         1: .line 246
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$5(Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
         2: .line 299
            aload 1 /* handler */
         3: .line 246
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
         4: .line 245
            aload 2
            monitorexit
         5: goto 8
      StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager io.vertx.core.Handler java.lang.Object
      StackMap stack: java.lang.Throwable
         6: aload 2
            monitorexit
         7: athrow
         8: .line 301
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    9     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
      Exception table:
        from    to  target  type
           1     5       6  any
           6     7       6  any
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  private void releasePendingLocksForFailedNode(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String nodeId
         0: .line 307
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* processed */
        start local 2 // java.util.Set processed
         1: .line 309
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
            aload 0 /* this */
            aload 2 /* processed */
            aload 1 /* nodeId */
            invokedynamic accept(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/util/Set;Ljava/lang/String;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$8(Ljava/util/Set;Ljava/lang/String;Ljava/lang/String;)V (7)
                  (Ljava/lang/String;)V
            invokeinterface java.util.Queue.forEach:(Ljava/util/function/Consumer;)V
         2: .line 318
            return
        end local 2 // java.util.Set processed
        end local 1 // java.lang.String nodeId
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    3     1     nodeId  Ljava/lang/String;
            1    3     2  processed  Ljava/util/Set<Ljava/lang/String;>;
    MethodParameters:
        Name  Flags
      nodeId  final

  public void leave(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // io.vertx.core.Handler handler
         0: .line 322
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.monitor:Ljava/lang/Object;
            dup
            astore 2
            monitorenter
         1: .line 323
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$9(Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
         2: .line 337
            aload 1 /* handler */
         3: .line 323
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
         4: .line 322
            aload 2
            monitorexit
         5: goto 8
      StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager io.vertx.core.Handler java.lang.Object
      StackMap stack: java.lang.Throwable
         6: aload 2
            monitorexit
         7: athrow
         8: .line 339
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    9     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
      Exception table:
        from    to  target  type
           1     5       6  any
           6     7       6  any
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public boolean isActive();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
         0: .line 343
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
            ireturn
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;

  private org.apache.ignite.configuration.IgniteConfiguration loadConfiguration(java.net.URL);
    descriptor: (Ljava/net/URL;)Lorg/apache/ignite/configuration/IgniteConfiguration;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.net.URL config
         0: .line 348
            aload 1 /* config */
            invokestatic org.apache.ignite.internal.IgnitionEx.loadConfigurations:(Ljava/net/URL;)Lorg/apache/ignite/lang/IgniteBiTuple;
            invokevirtual org.apache.ignite.lang.IgniteBiTuple.get1:()Ljava/lang/Object;
            checkcast java.lang.Iterable
            invokestatic org.apache.ignite.internal.util.typedef.F.first:(Ljava/lang/Iterable;)Ljava/lang/Object;
            checkcast org.apache.ignite.configuration.IgniteConfiguration
            astore 2 /* cfg */
        start local 2 // org.apache.ignite.configuration.IgniteConfiguration cfg
         1: .line 349
            aload 0 /* this */
            aload 2 /* cfg */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.setNodeID:(Lorg/apache/ignite/configuration/IgniteConfiguration;)V
         2: .line 350
            aload 2 /* cfg */
         3: areturn
        end local 2 // org.apache.ignite.configuration.IgniteConfiguration cfg
         4: .line 351
      StackMap locals:
      StackMap stack: org.apache.ignite.IgniteCheckedException
            astore 2 /* e */
        start local 2 // org.apache.ignite.IgniteCheckedException e
         5: .line 352
            getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/logging/Logger;
            ldc "Configuration loading error:"
            aload 2 /* e */
            invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         6: .line 353
            new java.lang.RuntimeException
            dup
            aload 2 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 2 // org.apache.ignite.IgniteCheckedException e
        end local 1 // java.net.URL config
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    7     1  config  Ljava/net/URL;
            1    4     2     cfg  Lorg/apache/ignite/configuration/IgniteConfiguration;
            5    7     2       e  Lorg/apache/ignite/IgniteCheckedException;
      Exception table:
        from    to  target  type
           0     3       4  Class org.apache.ignite.IgniteCheckedException
    MethodParameters:
        Name  Flags
      config  

  private org.apache.ignite.configuration.IgniteConfiguration loadConfiguration();
    descriptor: ()Lorg/apache/ignite/configuration/IgniteConfiguration;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=4, args_size=1
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
         0: .line 358
            invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
            invokevirtual java.lang.Thread.getContextClassLoader:()Ljava/lang/ClassLoader;
            astore 1 /* ctxClsLoader */
        start local 1 // java.lang.ClassLoader ctxClsLoader
         1: .line 360
            aconst_null
            astore 2 /* is */
        start local 2 // java.io.InputStream is
         2: .line 362
            aload 1 /* ctxClsLoader */
            ifnull 4
         3: .line 363
            aload 1 /* ctxClsLoader */
            ldc "ignite.xml"
            invokevirtual java.lang.ClassLoader.getResourceAsStream:(Ljava/lang/String;)Ljava/io/InputStream;
            astore 2 /* is */
         4: .line 366
      StackMap locals: java.lang.ClassLoader java.io.InputStream
      StackMap stack:
            aload 2 /* is */
            ifnonnull 9
         5: .line 367
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
            ldc "ignite.xml"
            invokevirtual java.lang.ClassLoader.getResourceAsStream:(Ljava/lang/String;)Ljava/io/InputStream;
            astore 2 /* is */
         6: .line 369
            aload 2 /* is */
            ifnonnull 9
         7: .line 370
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
            ldc "default-ignite.xml"
            invokevirtual java.lang.ClassLoader.getResourceAsStream:(Ljava/lang/String;)Ljava/io/InputStream;
            astore 2 /* is */
         8: .line 371
            getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/logging/Logger;
            ldc "Using default configuration."
            invokevirtual io.vertx.core.logging.Logger.info:(Ljava/lang/Object;)V
         9: .line 376
      StackMap locals:
      StackMap stack:
            aload 2 /* is */
            invokestatic org.apache.ignite.internal.IgnitionEx.loadConfigurations:(Ljava/io/InputStream;)Lorg/apache/ignite/lang/IgniteBiTuple;
            invokevirtual org.apache.ignite.lang.IgniteBiTuple.get1:()Ljava/lang/Object;
            checkcast java.lang.Iterable
            invokestatic org.apache.ignite.internal.util.typedef.F.first:(Ljava/lang/Iterable;)Ljava/lang/Object;
            checkcast org.apache.ignite.configuration.IgniteConfiguration
            astore 3 /* cfg */
        start local 3 // org.apache.ignite.configuration.IgniteConfiguration cfg
        10: .line 377
            aload 0 /* this */
            aload 3 /* cfg */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.setNodeID:(Lorg/apache/ignite/configuration/IgniteConfiguration;)V
        11: .line 378
            aload 3 /* cfg */
        12: areturn
        end local 3 // org.apache.ignite.configuration.IgniteConfiguration cfg
        13: .line 379
      StackMap locals:
      StackMap stack: org.apache.ignite.IgniteCheckedException
            astore 3 /* e */
        start local 3 // org.apache.ignite.IgniteCheckedException e
        14: .line 380
            getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/logging/Logger;
            ldc "Configuration loading error:"
            aload 3 /* e */
            invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
        15: .line 381
            new java.lang.RuntimeException
            dup
            aload 3 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 3 // org.apache.ignite.IgniteCheckedException e
        end local 2 // java.io.InputStream is
        end local 1 // java.lang.ClassLoader ctxClsLoader
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   16     0          this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            1   16     1  ctxClsLoader  Ljava/lang/ClassLoader;
            2   16     2            is  Ljava/io/InputStream;
           10   13     3           cfg  Lorg/apache/ignite/configuration/IgniteConfiguration;
           14   16     3             e  Lorg/apache/ignite/IgniteCheckedException;
      Exception table:
        from    to  target  type
           9    12      13  Class org.apache.ignite.IgniteCheckedException

  private void setNodeID(org.apache.ignite.configuration.IgniteConfiguration);
    descriptor: (Lorg/apache/ignite/configuration/IgniteConfiguration;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // org.apache.ignite.configuration.IgniteConfiguration cfg
         0: .line 386
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeID:Ljava/lang/String;
            invokestatic java.util.UUID.fromString:(Ljava/lang/String;)Ljava/util/UUID;
            astore 2 /* uuid */
        start local 2 // java.util.UUID uuid
         1: .line 387
            aload 1 /* cfg */
            aload 2 /* uuid */
            invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setNodeId:(Ljava/util/UUID;)Lorg/apache/ignite/configuration/IgniteConfiguration;
            pop
         2: .line 388
            aload 1 /* cfg */
            new java.lang.StringBuilder
            dup
            ldc "vertx.ignite.node."
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* uuid */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual org.apache.ignite.configuration.IgniteConfiguration.setIgniteInstanceName:(Ljava/lang/String;)Lorg/apache/ignite/configuration/IgniteConfiguration;
            pop
         3: .line 389
            return
        end local 2 // java.util.UUID uuid
        end local 1 // org.apache.ignite.configuration.IgniteConfiguration cfg
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    4     1   cfg  Lorg/apache/ignite/configuration/IgniteConfiguration;
            1    4     2  uuid  Ljava/util/UUID;
    MethodParameters:
      Name  Flags
      cfg   

  private <K, V> org.apache.ignite.IgniteCache<K, V> getCache(java.lang.String);
    descriptor: (Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String name
         0: .line 392
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            aload 1 /* name */
            invokeinterface org.apache.ignite.Ignite.getOrCreateCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
            astore 2 /* cache */
        start local 2 // org.apache.ignite.IgniteCache cache
         1: .line 393
            aload 2 /* cache */
            getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.DEFAULT_EXPIRY_POLICY:Ljavax/cache/expiry/ExpiryPolicy;
            invokeinterface org.apache.ignite.IgniteCache.withExpiryPolicy:(Ljavax/cache/expiry/ExpiryPolicy;)Lorg/apache/ignite/IgniteCache;
            areturn
        end local 2 // org.apache.ignite.IgniteCache cache
        end local 1 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    2     1   name  Ljava/lang/String;
            1    2     2  cache  Lorg/apache/ignite/IgniteCache<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache<TK;TV;>;
    MethodParameters:
      Name  Flags
      name  

  private <T> org.apache.ignite.IgniteQueue<T> getQueue(java.lang.String, boolean);
    descriptor: (Ljava/lang/String;Z)Lorg/apache/ignite/IgniteQueue;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // java.lang.String name
        start local 2 // boolean create
         0: .line 397
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            aload 1 /* name */
            iconst_1
            iload 2 /* create */
            ifeq 1
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.collectionCfg:Lorg/apache/ignite/configuration/CollectionConfiguration;
            goto 2
      StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager java.lang.String int
      StackMap stack: org.apache.ignite.Ignite java.lang.String int
         1: aconst_null
      StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager java.lang.String int
      StackMap stack: org.apache.ignite.Ignite java.lang.String int org.apache.ignite.configuration.CollectionConfiguration
         2: invokeinterface org.apache.ignite.Ignite.queue:(Ljava/lang/String;ILorg/apache/ignite/configuration/CollectionConfiguration;)Lorg/apache/ignite/IgniteQueue;
            areturn
        end local 2 // boolean create
        end local 1 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     0    this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    3     1    name  Ljava/lang/String;
            0    3     2  create  Z
    Signature: <T:Ljava/lang/Object;>(Ljava/lang/String;Z)Lorg/apache/ignite/IgniteQueue<TT;>;
    MethodParameters:
        Name  Flags
      name    
      create  

  private static java.lang.String nodeId(org.apache.ignite.cluster.ClusterNode);
    descriptor: (Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.ignite.cluster.ClusterNode node
         0: .line 401
            aload 0 /* node */
            invokeinterface org.apache.ignite.cluster.ClusterNode.id:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            areturn
        end local 0 // org.apache.ignite.cluster.ClusterNode node
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  node  Lorg/apache/ignite/cluster/ClusterNode;
    MethodParameters:
      Name  Flags
      node  

  static org.apache.ignite.IgniteQueue access$0(io.vertx.spi.cluster.ignite.IgniteClusterManager, java.lang.String, boolean);
    descriptor: (Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;Z)Lorg/apache/ignite/IgniteQueue;
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 396
            aload 0
            aload 1
            iload 2
            invokespecial io.vertx.spi.cluster.ignite.IgniteClusterManager.getQueue:(Ljava/lang/String;Z)Lorg/apache/ignite/IgniteQueue;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void lambda$0(java.lang.String, io.vertx.core.Promise);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 2 // io.vertx.core.Promise fut
         0: .line 174
            aload 2 /* fut */
            new io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl
            dup
            aload 0 /* this */
            aload 1
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
            invokespecial io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.<init>:(Lorg/apache/ignite/IgniteCache;Lio/vertx/core/Vertx;)V
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
            return
        end local 2 // io.vertx.core.Promise fut
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    1     2   fut  Lio/vertx/core/Promise<Lio/vertx/core/spi/cluster/AsyncMultiMap<TK;TV;>;>;

  private void lambda$1(java.lang.String, io.vertx.core.Promise);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 2 // io.vertx.core.Promise fut
         0: .line 181
            aload 2 /* fut */
            new io.vertx.spi.cluster.ignite.impl.AsyncMapImpl
            dup
            aload 0 /* this */
            aload 1
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getCache:(Ljava/lang/String;)Lorg/apache/ignite/IgniteCache;
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
            invokespecial io.vertx.spi.cluster.ignite.impl.AsyncMapImpl.<init>:(Lorg/apache/ignite/IgniteCache;Lio/vertx/core/Vertx;)V
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
            return
        end local 2 // io.vertx.core.Promise fut
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    1     2   fut  Lio/vertx/core/Promise<Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;>;

  private void lambda$2(java.lang.String, long, io.vertx.core.Promise);
    descriptor: (Ljava/lang/String;JLio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=10, args_size=4
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 4 // io.vertx.core.Promise fut
         0: .line 196
            aload 0 /* this */
            aload 1
            iconst_1
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getQueue:(Ljava/lang/String;Z)Lorg/apache/ignite/IgniteQueue;
            astore 6 /* queue */
        start local 6 // org.apache.ignite.IgniteQueue queue
         1: .line 198
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
            aload 1
            invokeinterface java.util.Queue.offer:(Ljava/lang/Object;)Z
            pop
         2: .line 200
            aload 6 /* queue */
            aload 0 /* this */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getNodeID:()Ljava/lang/String;
            lload 2
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface org.apache.ignite.IgniteQueue.offer:(Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Z
            istore 5 /* locked */
        start local 5 // boolean locked
         3: .line 202
            iload 5 /* locked */
            ifne 15
         4: .line 206
            aload 6 /* queue */
            invokeinterface org.apache.ignite.IgniteQueue.peek:()Ljava/lang/Object;
            checkcast java.lang.String
            astore 7 /* ownerId */
        start local 7 // java.lang.String ownerId
         5: .line 207
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            invokeinterface org.apache.ignite.Ignite.cluster:()Lorg/apache/ignite/IgniteCluster;
            aload 7 /* ownerId */
            invokestatic java.util.UUID.fromString:(Ljava/lang/String;)Ljava/util/UUID;
            iconst_0
            anewarray java.util.UUID
            invokeinterface org.apache.ignite.IgniteCluster.forNodeId:(Ljava/util/UUID;[Ljava/util/UUID;)Lorg/apache/ignite/cluster/ClusterGroup;
            invokeinterface org.apache.ignite.cluster.ClusterGroup.node:()Lorg/apache/ignite/cluster/ClusterNode;
            astore 8 /* ownerNode */
        start local 8 // org.apache.ignite.cluster.ClusterNode ownerNode
         6: .line 208
            aload 8 /* ownerNode */
            ifnonnull 15
         7: .line 209
            aload 6 /* queue */
            aload 7 /* ownerId */
            invokeinterface org.apache.ignite.IgniteQueue.remove:(Ljava/lang/Object;)Z
            pop
         8: .line 210
            aload 6 /* queue */
            aload 0 /* this */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getNodeID:()Ljava/lang/String;
            lload 2
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            invokeinterface org.apache.ignite.IgniteQueue.offer:(Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Z
            istore 5 /* locked */
        end local 8 // org.apache.ignite.cluster.ClusterNode ownerNode
        end local 7 // java.lang.String ownerId
        end local 6 // org.apache.ignite.IgniteQueue queue
         9: .line 213
            goto 15
        end local 5 // boolean locked
      StackMap locals:
      StackMap stack: java.lang.Exception
        10: astore 6 /* e */
        start local 6 // java.lang.Exception e
        11: .line 214
            new io.vertx.core.VertxException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Error during getting lock "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 6 /* e */
            invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 6 // java.lang.Exception e
        12: .line 215
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 9
        13: .line 216
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
            aload 1
            invokeinterface java.util.Queue.remove:(Ljava/lang/Object;)Z
            pop
        14: .line 217
            aload 9
            athrow
        start local 5 // boolean locked
        15: .line 216
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.pendingLocks:Ljava/util/Queue;
            aload 1
            invokeinterface java.util.Queue.remove:(Ljava/lang/Object;)Z
            pop
        16: .line 219
            iload 5 /* locked */
            ifeq 19
        17: .line 220
            aload 4 /* fut */
            new io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl
            dup
            aload 0 /* this */
            aload 1
            invokespecial io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl.<init>:(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Ljava/lang/String;)V
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        18: .line 221
            goto 20
        19: .line 222
      StackMap locals:
      StackMap stack:
            new io.vertx.core.VertxException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Timed out waiting to get lock "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial io.vertx.core.VertxException.<init>:(Ljava/lang/String;)V
            athrow
        end local 5 // boolean locked
        20: .line 224
      StackMap locals:
      StackMap stack:
            return
        end local 4 // io.vertx.core.Promise fut
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   21     0       this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0   21     4        fut  Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;
            3   10     5     locked  Z
           15   20     5     locked  Z
            1    9     6      queue  Lorg/apache/ignite/IgniteQueue<Ljava/lang/String;>;
            5    9     7    ownerId  Ljava/lang/String;
            6    9     8  ownerNode  Lorg/apache/ignite/cluster/ClusterNode;
           11   12     6          e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0     9      10  Class java.lang.Exception
           0    12      12  any

  private void lambda$3(java.lang.String, io.vertx.core.Promise);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=9, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 2 // io.vertx.core.Promise fut
         0: .line 229
            aload 2 /* fut */
            new io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl
            dup
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            aload 1
            lconst_0
            iconst_1
            invokeinterface org.apache.ignite.Ignite.atomicLong:(Ljava/lang/String;JZ)Lorg/apache/ignite/IgniteAtomicLong;
            invokespecial io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl.<init>:(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Lorg/apache/ignite/IgniteAtomicLong;)V
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
            return
        end local 2 // io.vertx.core.Promise fut
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    1     2   fut  Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Counter;>;

  private void lambda$5(io.vertx.core.Promise);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=6, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // io.vertx.core.Promise fut
         0: .line 247
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
            ifne 21
         1: .line 248
            aload 0 /* this */
            iconst_1
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
         2: .line 250
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.customIgnite:Z
            ifne 6
         3: .line 251
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
            ifnonnull 4
            aload 0 /* this */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.loadConfiguration:()Lorg/apache/ignite/configuration/IgniteConfiguration;
            invokestatic org.apache.ignite.Ignition.start:(Lorg/apache/ignite/configuration/IgniteConfiguration;)Lorg/apache/ignite/Ignite;
            goto 5
      StackMap locals:
      StackMap stack: io.vertx.spi.cluster.ignite.IgniteClusterManager
         4: aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.cfg:Lorg/apache/ignite/configuration/IgniteConfiguration;
            invokestatic org.apache.ignite.Ignition.start:(Lorg/apache/ignite/configuration/IgniteConfiguration;)Lorg/apache/ignite/Ignite;
      StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager io.vertx.core.Promise
      StackMap stack: io.vertx.spi.cluster.ignite.IgniteClusterManager org.apache.ignite.Ignite
         5: putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
         6: .line 253
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            invokeinterface org.apache.ignite.Ignite.cluster:()Lorg/apache/ignite/IgniteCluster;
            invokeinterface org.apache.ignite.IgniteCluster.localNode:()Lorg/apache/ignite/cluster/ClusterNode;
            invokestatic io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeID:Ljava/lang/String;
         7: .line 255
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            invokeinterface org.apache.ignite.Ignite.configuration:()Lorg/apache/ignite/configuration/IgniteConfiguration;
            invokevirtual org.apache.ignite.configuration.IgniteConfiguration.getCacheConfiguration:()[Lorg/apache/ignite/configuration/CacheConfiguration;
            dup
            astore 5
            arraylength
            istore 4
            iconst_0
            istore 3
            goto 15
      StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager io.vertx.core.Promise top int int org.apache.ignite.configuration.CacheConfiguration[]
      StackMap stack:
         8: aload 5
            iload 3
            aaload
            astore 2 /* cacheCfg */
        start local 2 // org.apache.ignite.configuration.CacheConfiguration cacheCfg
         9: .line 256
            aload 2 /* cacheCfg */
            invokevirtual org.apache.ignite.configuration.CacheConfiguration.getName:()Ljava/lang/String;
            ldc "*"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 14
        10: .line 257
            aload 0 /* this */
            new org.apache.ignite.configuration.CollectionConfiguration
            dup
            invokespecial org.apache.ignite.configuration.CollectionConfiguration.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.collectionCfg:Lorg/apache/ignite/configuration/CollectionConfiguration;
        11: .line 258
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.collectionCfg:Lorg/apache/ignite/configuration/CollectionConfiguration;
            aload 2 /* cacheCfg */
            invokevirtual org.apache.ignite.configuration.CacheConfiguration.getAtomicityMode:()Lorg/apache/ignite/cache/CacheAtomicityMode;
            invokevirtual org.apache.ignite.configuration.CollectionConfiguration.setAtomicityMode:(Lorg/apache/ignite/cache/CacheAtomicityMode;)Lorg/apache/ignite/configuration/CollectionConfiguration;
            pop
        12: .line 259
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.collectionCfg:Lorg/apache/ignite/configuration/CollectionConfiguration;
            aload 2 /* cacheCfg */
            invokevirtual org.apache.ignite.configuration.CacheConfiguration.getBackups:()I
            invokevirtual org.apache.ignite.configuration.CollectionConfiguration.setBackups:(I)Lorg/apache/ignite/configuration/CollectionConfiguration;
            pop
        13: .line 260
            goto 16
        end local 2 // org.apache.ignite.configuration.CacheConfiguration cacheCfg
        14: .line 255
      StackMap locals:
      StackMap stack:
            iinc 3 1
      StackMap locals:
      StackMap stack:
        15: iload 3
            iload 4
            if_icmplt 8
        16: .line 264
      StackMap locals: io.vertx.spi.cluster.ignite.IgniteClusterManager io.vertx.core.Promise
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.collectionCfg:Lorg/apache/ignite/configuration/CollectionConfiguration;
            ifnonnull 18
        17: .line 265
            aload 0 /* this */
            new org.apache.ignite.configuration.CollectionConfiguration
            dup
            invokespecial org.apache.ignite.configuration.CollectionConfiguration.<init>:()V
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.collectionCfg:Lorg/apache/ignite/configuration/CollectionConfiguration;
        18: .line 268
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* fut */
            invokedynamic apply(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Lio/vertx/core/Promise;)Lorg/apache/ignite/lang/IgnitePredicate;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Z
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$6(Lio/vertx/core/Promise;Lorg/apache/ignite/events/Event;)Z (7)
                  (Lorg/apache/ignite/events/Event;)Z
                  1
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
        19: .line 295
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            invokeinterface org.apache.ignite.Ignite.events:()Lorg/apache/ignite/IgniteEvents;
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
            iconst_3
            newarray 10
            dup
            iconst_0
            bipush 10
            iastore
            dup
            iconst_1
            bipush 11
            iastore
            dup
            iconst_2
            bipush 12
            iastore
            invokeinterface org.apache.ignite.IgniteEvents.localListen:(Lorg/apache/ignite/lang/IgnitePredicate;[I)V
        20: .line 297
            aload 1 /* fut */
            invokeinterface io.vertx.core.Promise.complete:()V
        21: .line 299
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Promise fut
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   22     0      this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0   22     1       fut  Lio/vertx/core/Promise<Ljava/lang/Void;>;
            9   14     2  cacheCfg  Lorg/apache/ignite/configuration/CacheConfiguration;

  private void lambda$8(java.util.Set, java.lang.String, java.lang.String);
    descriptor: (Ljava/util/Set;Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 3 // java.lang.String name
         0: .line 310
            aload 1
            aload 3 /* name */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            ifeq 4
         1: .line 311
            aload 0 /* this */
            aload 3 /* name */
            iconst_0
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.getQueue:(Ljava/lang/String;Z)Lorg/apache/ignite/IgniteQueue;
            astore 4 /* queue */
        start local 4 // org.apache.ignite.IgniteQueue queue
         2: .line 313
            aload 4 /* queue */
            ifnull 4
            aload 2
            aload 4 /* queue */
            invokeinterface org.apache.ignite.IgniteQueue.peek:()Ljava/lang/Object;
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 4
         3: .line 314
            aload 4 /* queue */
            aload 2
            invokeinterface org.apache.ignite.IgniteQueue.remove:(Ljava/lang/Object;)Z
            pop
        end local 4 // org.apache.ignite.IgniteQueue queue
         4: .line 317
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.lang.String name
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    5     3   name  Ljava/lang/String;
            2    4     4  queue  Lorg/apache/ignite/IgniteQueue<Ljava/lang/String;>;

  private void lambda$9(io.vertx.core.Promise);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=3, args_size=2
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 1 // io.vertx.core.Promise fut
         0: .line 324
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
            ifeq 9
         1: .line 325
            aload 0 /* this */
            iconst_0
            putfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
         2: .line 327
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.customIgnite:Z
            ifne 4
         3: .line 328
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            invokeinterface org.apache.ignite.Ignite.close:()V
            goto 9
         4: .line 329
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
            ifnull 9
         5: .line 330
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.ignite:Lorg/apache/ignite/Ignite;
            invokeinterface org.apache.ignite.Ignite.events:()Lorg/apache/ignite/IgniteEvents;
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.eventListener:Lorg/apache/ignite/lang/IgnitePredicate;
            iconst_3
            newarray 10
            dup
            iconst_0
            bipush 10
            iastore
            dup
            iconst_1
            bipush 11
            iastore
            dup
            iconst_2
            bipush 12
            iastore
            invokeinterface org.apache.ignite.IgniteEvents.stopLocalListen:(Lorg/apache/ignite/lang/IgnitePredicate;[I)Z
            pop
         6: .line 331
            goto 9
      StackMap locals:
      StackMap stack: java.lang.Exception
         7: astore 2 /* e */
        start local 2 // java.lang.Exception e
         8: .line 332
            getstatic io.vertx.spi.cluster.ignite.IgniteClusterManager.log:Lio/vertx/core/logging/Logger;
            aload 2 /* e */
            invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;)V
        end local 2 // java.lang.Exception e
         9: .line 336
      StackMap locals:
      StackMap stack:
            aload 1 /* fut */
            invokeinterface io.vertx.core.Promise.complete:()V
        10: .line 337
            return
        end local 1 // io.vertx.core.Promise fut
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   11     0  this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0   11     1   fut  Lio/vertx/core/Promise<Ljava/lang/Void;>;
            8    9     2     e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           2     6       7  Class java.lang.Exception

  private boolean lambda$6(io.vertx.core.Promise, org.apache.ignite.events.Event);
    descriptor: (Lio/vertx/core/Promise;Lorg/apache/ignite/events/Event;)Z
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 2 // org.apache.ignite.events.Event event
         0: .line 269
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.active:Z
            ifne 2
         1: .line 270
            iconst_0
            ireturn
         2: .line 273
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
            ifnull 6
         3: .line 274
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            aload 2 /* event */
            aload 1
            invokedynamic handle(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Lorg/apache/ignite/events/Event;Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$7(Lorg/apache/ignite/events/Event;Lio/vertx/core/Promise;Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
         4: .line 289
            aconst_null
         5: .line 274
            invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/Handler;)V
         6: .line 292
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 2 // org.apache.ignite.events.Event event
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    7     0   this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    7     2  event  Lorg/apache/ignite/events/Event;

  private void lambda$7(org.apache.ignite.events.Event, io.vertx.core.Promise, io.vertx.core.Promise);
    descriptor: (Lorg/apache/ignite/events/Event;Lio/vertx/core/Promise;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=5, args_size=4
        start local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
        start local 3 // io.vertx.core.Promise f
         0: .line 275
            aload 0 /* this */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.isActive:()Z
            ifeq 7
         1: .line 276
            aload 1
            invokeinterface org.apache.ignite.events.Event.type:()I
            tableswitch { // 10 - 12
                   10: 2
                   11: 4
                   12: 4
              default: 7
          }
         2: .line 278
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
            aload 1
            checkcast org.apache.ignite.events.DiscoveryEvent
            invokevirtual org.apache.ignite.events.DiscoveryEvent.eventNode:()Lorg/apache/ignite/cluster/ClusterNode;
            invokestatic io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
            invokeinterface io.vertx.core.spi.cluster.NodeListener.nodeAdded:(Ljava/lang/String;)V
         3: .line 279
            goto 7
         4: .line 282
      StackMap locals:
      StackMap stack:
            aload 1
            checkcast org.apache.ignite.events.DiscoveryEvent
            invokevirtual org.apache.ignite.events.DiscoveryEvent.eventNode:()Lorg/apache/ignite/cluster/ClusterNode;
            invokestatic io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeId:(Lorg/apache/ignite/cluster/ClusterNode;)Ljava/lang/String;
            astore 4 /* nodeId */
        start local 4 // java.lang.String nodeId
         5: .line 283
            aload 0 /* this */
            getfield io.vertx.spi.cluster.ignite.IgniteClusterManager.nodeListener:Lio/vertx/core/spi/cluster/NodeListener;
            aload 4 /* nodeId */
            invokeinterface io.vertx.core.spi.cluster.NodeListener.nodeLeft:(Ljava/lang/String;)V
         6: .line 284
            aload 0 /* this */
            aload 4 /* nodeId */
            invokevirtual io.vertx.spi.cluster.ignite.IgniteClusterManager.releasePendingLocksForFailedNode:(Ljava/lang/String;)V
        end local 4 // java.lang.String nodeId
         7: .line 288
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface io.vertx.core.Promise.complete:()V
         8: .line 289
            return
        end local 3 // io.vertx.core.Promise f
        end local 0 // io.vertx.spi.cluster.ignite.IgniteClusterManager this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    9     0    this  Lio/vertx/spi/cluster/ignite/IgniteClusterManager;
            0    9     3       f  Lio/vertx/core/Promise<Ljava/lang/Object;>;
            5    7     4  nodeId  Ljava/lang/String;

  private static java.lang.Object $deserializeLambda$(java.lang.invoke.SerializedLambda);
    descriptor: (Ljava/lang/invoke/SerializedLambda;)Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=5, locals=3, args_size=1
         0: .line 1
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodName:()Ljava/lang/String;
            astore 1
            iconst_m1
            istore 2
            aload 1
            invokevirtual java.lang.String.hashCode:()I
            lookupswitch { // 1
          -1647344999: 1
              default: 2
          }
      StackMap locals: java.lang.String int
      StackMap stack:
         1: aload 1
            ldc "lambda$6"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 2
            iconst_0
            istore 2
      StackMap locals:
      StackMap stack:
         2: iload 2
            lookupswitch { // 1
                    0: 3
              default: 4
          }
      StackMap locals:
      StackMap stack:
         3: aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
            bipush 7
            if_icmpne 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
            ldc "org/apache/ignite/lang/IgnitePredicate"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
            ldc "apply"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
            ldc "(Ljava/lang/Object;)Z"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
            ldc "io/vertx/spi/cluster/ignite/IgniteClusterManager"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
            ldc "(Lio/vertx/core/Promise;Lorg/apache/ignite/events/Event;)Z"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            iconst_0
            invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
            checkcast io.vertx.spi.cluster.ignite.IgniteClusterManager
            aload 0
            iconst_1
            invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
            checkcast io.vertx.core.Promise
            invokedynamic apply(Lio/vertx/spi/cluster/ignite/IgniteClusterManager;Lio/vertx/core/Promise;)Lorg/apache/ignite/lang/IgnitePredicate;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Z
                  io/vertx/spi/cluster/ignite/IgniteClusterManager.lambda$6(Lio/vertx/core/Promise;Lorg/apache/ignite/events/Event;)Z (7)
                  (Lorg/apache/ignite/events/Event;)Z
                  1
            areturn
      StackMap locals:
      StackMap stack:
         4: new java.lang.IllegalArgumentException
            dup
            ldc "Invalid lambda deserialization"
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
SourceFile: "IgniteClusterManager.java"
NestMembers:
  io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy  io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl  io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl
InnerClasses:
  private ClearExpiryPolicy = io.vertx.spi.cluster.ignite.IgniteClusterManager$ClearExpiryPolicy of io.vertx.spi.cluster.ignite.IgniteClusterManager
  private CounterImpl = io.vertx.spi.cluster.ignite.IgniteClusterManager$CounterImpl of io.vertx.spi.cluster.ignite.IgniteClusterManager
  private LockImpl = io.vertx.spi.cluster.ignite.IgniteClusterManager$LockImpl of io.vertx.spi.cluster.ignite.IgniteClusterManager
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles