public class io.vertx.ext.stomp.DefaultUnsubscribeHandler implements io.vertx.core.Handler<io.vertx.ext.stomp.ServerFrame>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.stomp.DefaultUnsubscribeHandler
super_class: java.lang.Object
{
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/DefaultUnsubscribeHandler;
public void handle(io.vertx.ext.stomp.ServerFrame);
descriptor: (Lio/vertx/ext/stomp/ServerFrame;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=9, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.ext.stomp.ServerFrame.frame:()Lio/vertx/ext/stomp/Frame;
astore 2
start local 2 1: aload 1
invokeinterface io.vertx.ext.stomp.ServerFrame.connection:()Lio/vertx/ext/stomp/StompServerConnection;
astore 3
start local 3 2: aload 2
ldc "id"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
astore 4
start local 4 3: aload 4
ifnonnull 12
4: aload 3
5: ldc "Invalid unsubscribe"
6: aload 2
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;
7: ldc "The 'id' header must be set"
8: invokestatic io.vertx.ext.stomp.Frames.createErrorFrame:(Ljava/lang/String;Ljava/util/Map;Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
9: invokeinterface io.vertx.ext.stomp.StompServerConnection.write:(Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompServerConnection;
pop
10: aload 3
invokeinterface io.vertx.ext.stomp.StompServerConnection.close:()V
11: return
12: StackMap locals: io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection java.lang.String
StackMap stack:
aload 3
invokeinterface io.vertx.ext.stomp.StompServerConnection.handler:()Lio/vertx/ext/stomp/StompServerHandler;
invokeinterface io.vertx.ext.stomp.StompServerHandler.getDestinations:()Ljava/util/List;
astore 5
start local 5 13: iconst_0
istore 6
start local 6 14: aload 5
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 8
goto 19
StackMap locals: io.vertx.ext.stomp.DefaultUnsubscribeHandler io.vertx.ext.stomp.ServerFrame io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection java.lang.String java.util.List int top java.util.Iterator
StackMap stack:
15: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.ext.stomp.Destination
astore 7
start local 7 16: aload 7
aload 3
aload 2
invokeinterface io.vertx.ext.stomp.Destination.unsubscribe:(Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)Z
ifeq 19
17: iconst_1
istore 6
18: goto 20
end local 7 19: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 15
20: StackMap locals: io.vertx.ext.stomp.DefaultUnsubscribeHandler io.vertx.ext.stomp.ServerFrame io.vertx.ext.stomp.Frame io.vertx.ext.stomp.StompServerConnection java.lang.String java.util.List int
StackMap stack:
iload 6
ifne 28
21: aload 3
22: ldc "Invalid unsubscribe"
23: aload 2
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;
24: ldc "No subscription associated with the given 'id'"
25: invokestatic io.vertx.ext.stomp.Frames.createErrorFrame:(Ljava/lang/String;Ljava/util/Map;Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
invokeinterface io.vertx.ext.stomp.StompServerConnection.write:(Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompServerConnection;
pop
26: aload 3
invokeinterface io.vertx.ext.stomp.StompServerConnection.close:()V
27: return
28: StackMap locals:
StackMap stack:
aload 2
aload 3
invokestatic io.vertx.ext.stomp.Frames.handleReceipt:(Lio/vertx/ext/stomp/Frame;Lio/vertx/ext/stomp/StompServerConnection;)V
29: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 30 0 this Lio/vertx/ext/stomp/DefaultUnsubscribeHandler;
0 30 1 serverFrame Lio/vertx/ext/stomp/ServerFrame;
1 30 2 frame Lio/vertx/ext/stomp/Frame;
2 30 3 connection Lio/vertx/ext/stomp/StompServerConnection;
3 30 4 id Ljava/lang/String;
13 30 5 destinations Ljava/util/List<Lio/vertx/ext/stomp/Destination;>;
14 30 6 handled Z
16 19 7 destination Lio/vertx/ext/stomp/Destination;
MethodParameters:
Name Flags
serverFrame
public void handle(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.ext.stomp.ServerFrame
invokevirtual io.vertx.ext.stomp.DefaultUnsubscribeHandler.handle:(Lio/vertx/ext/stomp/ServerFrame;)V
return
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Ljava/lang/Object;Lio/vertx/core/Handler<Lio/vertx/ext/stomp/ServerFrame;>;
SourceFile: "DefaultUnsubscribeHandler.java"