io.vertx/vertx-stomp/4.0.0 : io/vertx/ext/stomp/impl/Topic.class

Topic
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-stomp: Stomp support for Vert.x 3 (Eclipse)
public class io.vertx.ext.stomp.impl.Topic implements io.vertx.ext.stomp.Destination
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.ext.stomp.impl.Topic
  super_class: java.lang.Object
{
  protected final java.lang.String destination;
    descriptor: Ljava/lang/String;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  protected final java.util.List<io.vertx.ext.stomp.impl.Topic$Subscription> subscriptions;
    descriptor: Ljava/util/List;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Signature: Ljava/util/List<Lio/vertx/ext/stomp/impl/Topic$Subscription;>;

  protected final io.vertx.core.Vertx vertx;
    descriptor: Lio/vertx/core/Vertx;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL

  public void <init>(io.vertx.core.Vertx, java.lang.String);
    descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // java.lang.String destination
         0: .line 42
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 39
            aload 0 /* this */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            putfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
         2: .line 43
            aload 0 /* this */
            aload 2 /* destination */
            putfield io.vertx.ext.stomp.impl.Topic.destination:Ljava/lang/String;
         3: .line 44
            aload 0 /* this */
            aload 1 /* vertx */
            putfield io.vertx.ext.stomp.impl.Topic.vertx:Lio/vertx/core/Vertx;
         4: .line 45
            return
        end local 2 // java.lang.String destination
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    5     0         this  Lio/vertx/ext/stomp/impl/Topic;
            0    5     1        vertx  Lio/vertx/core/Vertx;
            0    5     2  destination  Ljava/lang/String;
    MethodParameters:
             Name  Flags
      vertx        
      destination  

  public java.lang.String destination();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.Topic this
         0: .line 52
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.destination:Ljava/lang/String;
            areturn
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/ext/stomp/impl/Topic;

  public synchronized io.vertx.ext.stomp.Destination dispatch(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Frame);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/Destination;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=7, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.ext.stomp.StompServerConnection connection
        start local 2 // io.vertx.ext.stomp.Frame frame
         0: .line 64
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 4
            goto 5
      StackMap locals: io.vertx.ext.stomp.impl.Topic io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame top java.util.Iterator
      StackMap stack:
         1: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.ext.stomp.impl.Topic$Subscription
            astore 3 /* subscription */
        start local 3 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
         2: .line 65
            invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            astore 5 /* messageId */
        start local 5 // java.lang.String messageId
         3: .line 66
            aload 2 /* frame */
            aload 3 /* subscription */
            aload 5 /* messageId */
            invokestatic io.vertx.ext.stomp.impl.Topic.transform:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/impl/Topic$Subscription;Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
            astore 6 /* message */
        start local 6 // io.vertx.ext.stomp.Frame message
         4: .line 67
            aload 3 /* subscription */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
            aload 6 /* message */
            invokeinterface io.vertx.ext.stomp.StompServerConnection.write:(Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompServerConnection;
            pop
        end local 6 // io.vertx.ext.stomp.Frame message
        end local 5 // java.lang.String messageId
        end local 3 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
         5: .line 64
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         6: .line 69
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.ext.stomp.Frame frame
        end local 1 // io.vertx.ext.stomp.StompServerConnection connection
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lio/vertx/ext/stomp/impl/Topic;
            0    7     1    connection  Lio/vertx/ext/stomp/StompServerConnection;
            0    7     2         frame  Lio/vertx/ext/stomp/Frame;
            2    5     3  subscription  Lio/vertx/ext/stomp/impl/Topic$Subscription;
            3    5     5     messageId  Ljava/lang/String;
            4    5     6       message  Lio/vertx/ext/stomp/Frame;
    MethodParameters:
            Name  Flags
      connection  
      frame       

  public static io.vertx.ext.stomp.Frame transform(io.vertx.ext.stomp.Frame, io.vertx.ext.stomp.impl.Topic$Subscription, java.lang.String);
    descriptor: (Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/impl/Topic$Subscription;Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.vertx.ext.stomp.Frame frame
        start local 1 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
        start local 2 // java.lang.String messageId
         0: .line 73
            aload 0 /* frame */
            invokevirtual io.vertx.ext.stomp.Frame.getHeaders:()Ljava/util/Map;
            invokestatic io.vertx.ext.stomp.utils.Headers.create:(Ljava/util/Map;)Lio/vertx/ext/stomp/utils/Headers;
         1: .line 75
            ldc "subscription"
            aload 1 /* subscription */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.id:Ljava/lang/String;
            invokevirtual io.vertx.ext.stomp.utils.Headers.add:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
         2: .line 76
            ldc "message-id"
            aload 2 /* messageId */
            invokevirtual io.vertx.ext.stomp.utils.Headers.add:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
         3: .line 73
            astore 3 /* headers */
        start local 3 // io.vertx.ext.stomp.utils.Headers headers
         4: .line 77
            aload 1 /* subscription */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.ackMode:Ljava/lang/String;
            ldc "auto"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifne 6
         5: .line 79
            aload 3 /* headers */
            ldc "ack"
            aload 2 /* messageId */
            invokevirtual io.vertx.ext.stomp.utils.Headers.add:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
            pop
         6: .line 81
      StackMap locals: io.vertx.ext.stomp.utils.Headers
      StackMap stack:
            new io.vertx.ext.stomp.Frame
            dup
            getstatic io.vertx.ext.stomp.Frame$Command.MESSAGE:Lio/vertx/ext/stomp/Frame$Command;
         7: .line 82
            aload 3 /* headers */
         8: .line 83
            aload 0 /* frame */
            invokevirtual io.vertx.ext.stomp.Frame.getBody:()Lio/vertx/core/buffer/Buffer;
         9: .line 81
            invokespecial io.vertx.ext.stomp.Frame.<init>:(Lio/vertx/ext/stomp/Frame$Command;Ljava/util/Map;Lio/vertx/core/buffer/Buffer;)V
            areturn
        end local 3 // io.vertx.ext.stomp.utils.Headers headers
        end local 2 // java.lang.String messageId
        end local 1 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
        end local 0 // io.vertx.ext.stomp.Frame frame
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   10     0         frame  Lio/vertx/ext/stomp/Frame;
            0   10     1  subscription  Lio/vertx/ext/stomp/impl/Topic$Subscription;
            0   10     2     messageId  Ljava/lang/String;
            4   10     3       headers  Lio/vertx/ext/stomp/utils/Headers;
    MethodParameters:
              Name  Flags
      frame         
      subscription  
      messageId     

  public synchronized io.vertx.ext.stomp.Destination subscribe(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Frame);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/Destination;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.ext.stomp.StompServerConnection connection
        start local 2 // io.vertx.ext.stomp.Frame frame
         0: .line 96
            new io.vertx.ext.stomp.impl.Topic$Subscription
            dup
            aload 1 /* connection */
            aload 2 /* frame */
            invokespecial io.vertx.ext.stomp.impl.Topic$Subscription.<init>:(Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)V
            astore 3 /* subscription */
        start local 3 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
         1: .line 97
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            aload 3 /* subscription */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         2: .line 98
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
        end local 2 // io.vertx.ext.stomp.Frame frame
        end local 1 // io.vertx.ext.stomp.StompServerConnection connection
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/vertx/ext/stomp/impl/Topic;
            0    3     1    connection  Lio/vertx/ext/stomp/StompServerConnection;
            0    3     2         frame  Lio/vertx/ext/stomp/Frame;
            1    3     3  subscription  Lio/vertx/ext/stomp/impl/Topic$Subscription;
    MethodParameters:
            Name  Flags
      connection  
      frame       

  public synchronized boolean unsubscribe(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Frame);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=6, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.ext.stomp.StompServerConnection connection
        start local 2 // io.vertx.ext.stomp.Frame frame
         0: .line 110
            iconst_0
            istore 3 /* r */
        start local 3 // boolean r
         1: .line 111
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 5
            goto 6
      StackMap locals: io.vertx.ext.stomp.impl.Topic io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame int top java.util.Iterator
      StackMap stack:
         2: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.ext.stomp.impl.Topic$Subscription
            astore 4 /* subscription */
        start local 4 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
         3: .line 112
            aload 4 /* subscription */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
            aload 1 /* connection */
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 6
            aload 4 /* subscription */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.id:Ljava/lang/String;
            aload 2 /* frame */
            invokevirtual io.vertx.ext.stomp.Frame.getId:()Ljava/lang/String;
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 6
         4: .line 113
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            aload 4 /* subscription */
            invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
            istore 3 /* r */
         5: .line 115
            goto 7
        end local 4 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
         6: .line 111
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         7: .line 118
      StackMap locals: io.vertx.ext.stomp.impl.Topic io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame int
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            invokeinterface java.util.List.isEmpty:()Z
            ifeq 9
         8: .line 119
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.vertx:Lio/vertx/core/Vertx;
            invokeinterface io.vertx.core.Vertx.sharedData:()Lio/vertx/core/shareddata/SharedData;
            ldc "stomp.destinations"
            invokeinterface io.vertx.core.shareddata.SharedData.getLocalMap:(Ljava/lang/String;)Lio/vertx/core/shareddata/LocalMap;
            aload 0 /* this */
            invokeinterface io.vertx.core.shareddata.LocalMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         9: .line 121
      StackMap locals:
      StackMap stack:
            iload 3 /* r */
            ireturn
        end local 3 // boolean r
        end local 2 // io.vertx.ext.stomp.Frame frame
        end local 1 // io.vertx.ext.stomp.StompServerConnection connection
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   10     0          this  Lio/vertx/ext/stomp/impl/Topic;
            0   10     1    connection  Lio/vertx/ext/stomp/StompServerConnection;
            0   10     2         frame  Lio/vertx/ext/stomp/Frame;
            1   10     3             r  Z
            3    6     4  subscription  Lio/vertx/ext/stomp/impl/Topic$Subscription;
    MethodParameters:
            Name  Flags
      connection  
      frame       

  public synchronized io.vertx.ext.stomp.Destination unsubscribeConnection(io.vertx.ext.stomp.StompServerConnection);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;)Lio/vertx/ext/stomp/Destination;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.ext.stomp.StompServerConnection connection
         0: .line 132
            new java.util.ArrayList
            dup
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
         1: .line 133
            invokevirtual java.util.ArrayList.stream:()Ljava/util/stream/Stream;
         2: .line 134
            aload 1 /* connection */
            invokedynamic test(Lio/vertx/ext/stomp/StompServerConnection;)Ljava/util/function/Predicate;
              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;)Z
                  io/vertx/ext/stomp/impl/Topic.lambda$0(Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Z (6)
                  (Lio/vertx/ext/stomp/impl/Topic$Subscription;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
         3: .line 135
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic accept(Ljava/util/List;)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
                  java/util/List.remove(Ljava/lang/Object;)Z (9 itf)
                  (Lio/vertx/ext/stomp/impl/Topic$Subscription;)V
            invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
         4: .line 137
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            invokeinterface java.util.List.isEmpty:()Z
            ifeq 6
         5: .line 138
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.vertx:Lio/vertx/core/Vertx;
            invokeinterface io.vertx.core.Vertx.sharedData:()Lio/vertx/core/shareddata/SharedData;
            ldc "stomp.destinations"
            invokeinterface io.vertx.core.shareddata.SharedData.getLocalMap:(Ljava/lang/String;)Lio/vertx/core/shareddata/LocalMap;
            aload 0 /* this */
            invokeinterface io.vertx.core.shareddata.LocalMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 140
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.ext.stomp.StompServerConnection connection
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    7     0        this  Lio/vertx/ext/stomp/impl/Topic;
            0    7     1  connection  Lio/vertx/ext/stomp/StompServerConnection;
    MethodParameters:
            Name  Flags
      connection  

  public synchronized boolean ack(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Frame);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=3, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.ext.stomp.StompServerConnection connection
        start local 2 // io.vertx.ext.stomp.Frame frame
         0: .line 152
            iconst_0
            ireturn
        end local 2 // io.vertx.ext.stomp.Frame frame
        end local 1 // io.vertx.ext.stomp.StompServerConnection connection
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/vertx/ext/stomp/impl/Topic;
            0    1     1  connection  Lio/vertx/ext/stomp/StompServerConnection;
            0    1     2       frame  Lio/vertx/ext/stomp/Frame;
    MethodParameters:
            Name  Flags
      connection  
      frame       

  public synchronized boolean nack(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.Frame);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=3, args_size=3
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.ext.stomp.StompServerConnection connection
        start local 2 // io.vertx.ext.stomp.Frame frame
         0: .line 164
            iconst_0
            ireturn
        end local 2 // io.vertx.ext.stomp.Frame frame
        end local 1 // io.vertx.ext.stomp.StompServerConnection connection
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/vertx/ext/stomp/impl/Topic;
            0    1     1  connection  Lio/vertx/ext/stomp/StompServerConnection;
            0    1     2       frame  Lio/vertx/ext/stomp/Frame;
    MethodParameters:
            Name  Flags
      connection  
      frame       

  public synchronized java.util.List<java.lang.String> getSubscriptions(io.vertx.ext.stomp.StompServerConnection);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;)Ljava/util/List;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // io.vertx.ext.stomp.StompServerConnection connection
         0: .line 175
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
         1: .line 176
            aload 1 /* connection */
            invokedynamic test(Lio/vertx/ext/stomp/StompServerConnection;)Ljava/util/function/Predicate;
              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;)Z
                  io/vertx/ext/stomp/impl/Topic.lambda$2(Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Z (6)
                  (Lio/vertx/ext/stomp/impl/Topic$Subscription;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
         2: .line 177
            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/ext/stomp/impl/Topic.lambda$3(Lio/vertx/ext/stomp/impl/Topic$Subscription;)Ljava/lang/String; (6)
                  (Lio/vertx/ext/stomp/impl/Topic$Subscription;)Ljava/lang/String;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         3: .line 178
            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
         4: .line 175
            areturn
        end local 1 // io.vertx.ext.stomp.StompServerConnection connection
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0        this  Lio/vertx/ext/stomp/impl/Topic;
            0    5     1  connection  Lio/vertx/ext/stomp/StompServerConnection;
    Signature: (Lio/vertx/ext/stomp/StompServerConnection;)Ljava/util/List<Ljava/lang/String;>;
    MethodParameters:
            Name  Flags
      connection  

  public synchronized int numberOfSubscriptions();
    descriptor: ()I
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.Topic this
         0: .line 188
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.subscriptions:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            ireturn
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/ext/stomp/impl/Topic;

  public boolean matches(java.lang.String);
    descriptor: (Ljava/lang/String;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.stomp.impl.Topic this
        start local 1 // java.lang.String address
         0: .line 199
            aload 0 /* this */
            getfield io.vertx.ext.stomp.impl.Topic.destination:Ljava/lang/String;
            aload 1 /* address */
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ireturn
        end local 1 // java.lang.String address
        end local 0 // io.vertx.ext.stomp.impl.Topic this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/ext/stomp/impl/Topic;
            0    1     1  address  Ljava/lang/String;
    MethodParameters:
         Name  Flags
      address  

  private static boolean lambda$0(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.impl.Topic$Subscription);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Z
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
         0: .line 134
            aload 1 /* subscription */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
            aload 0
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ireturn
        end local 1 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    1     1  subscription  Lio/vertx/ext/stomp/impl/Topic$Subscription;

  private static boolean lambda$2(io.vertx.ext.stomp.StompServerConnection, io.vertx.ext.stomp.impl.Topic$Subscription);
    descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Z
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
         0: .line 176
            aload 1 /* subscription */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
            aload 0
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ireturn
        end local 1 // io.vertx.ext.stomp.impl.Topic$Subscription subscription
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    1     1  subscription  Lio/vertx/ext/stomp/impl/Topic$Subscription;

  private static java.lang.String lambda$3(io.vertx.ext.stomp.impl.Topic$Subscription);
    descriptor: (Lio/vertx/ext/stomp/impl/Topic$Subscription;)Ljava/lang/String;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.ext.stomp.impl.Topic$Subscription s
         0: .line 177
            aload 0 /* s */
            getfield io.vertx.ext.stomp.impl.Topic$Subscription.id:Ljava/lang/String;
            areturn
        end local 0 // io.vertx.ext.stomp.impl.Topic$Subscription s
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     s  Lio/vertx/ext/stomp/impl/Topic$Subscription;
}
SourceFile: "Topic.java"
NestMembers:
  io.vertx.ext.stomp.impl.Topic$Subscription
InnerClasses:
  public final Command = io.vertx.ext.stomp.Frame$Command of io.vertx.ext.stomp.Frame
  protected Subscription = io.vertx.ext.stomp.impl.Topic$Subscription of io.vertx.ext.stomp.impl.Topic
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
/

io.vertx/ vertx-stomp/ 4.0.0/ io/vertx/ext/stomp/impl/Topic.class
