public class io.vertx.ext.stomp.impl.EventBusBridge extends io.vertx.ext.stomp.impl.Topic
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.stomp.impl.EventBusBridge
super_class: io.vertx.ext.stomp.impl.Topic
{
private final io.vertx.ext.stomp.BridgeOptions options;
descriptor: Lio/vertx/ext/stomp/BridgeOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Map<java.lang.String, java.util.regex.Pattern> expressions;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Ljava/util/regex/Pattern;>;
private final java.util.Map<java.lang.String, io.vertx.core.eventbus.MessageConsumer<?>> registry;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lio/vertx/core/eventbus/MessageConsumer<*>;>;
public void <init>(io.vertx.core.Vertx, io.vertx.ext.stomp.BridgeOptions);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/ext/stomp/BridgeOptions;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aconst_null
invokespecial io.vertx.ext.stomp.impl.Topic.<init>:(Lio/vertx/core/Vertx;Ljava/lang/String;)V
1: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.ext.stomp.impl.EventBusBridge.expressions:Ljava/util/Map;
2: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.ext.stomp.impl.EventBusBridge.registry:Ljava/util/Map;
3: aload 0
aload 2
putfield io.vertx.ext.stomp.impl.EventBusBridge.options:Lio/vertx/ext/stomp/BridgeOptions;
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 5 1 vertx Lio/vertx/core/Vertx;
0 5 2 options Lio/vertx/ext/stomp/BridgeOptions;
MethodParameters:
Name Flags
vertx
options
public java.lang.String destination();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: ldc "<<bridge>>"
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
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=6, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokevirtual io.vertx.ext.stomp.Frame.getDestination:()Ljava/lang/String;
astore 3
start local 3 1: aload 0
iconst_0
aload 3
aconst_null
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.checkMatches:(ZLjava/lang/String;Ljava/lang/Object;)Z
ifeq 7
2: new io.vertx.ext.stomp.impl.Topic$Subscription
dup
aload 1
aload 2
invokespecial io.vertx.ext.stomp.impl.Topic$Subscription.<init>:(Lio/vertx/ext/stomp/StompServerConnection;Lio/vertx/ext/stomp/Frame;)V
astore 4
start local 4 3: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
aload 4
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
4: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.registry:Ljava/util/Map;
aload 3
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifne 6
5: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.registry:Ljava/util/Map;
aload 3
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.eventBus:()Lio/vertx/core/eventbus/EventBus;
aload 3
aload 0
aload 3
invokedynamic handle(Lio/vertx/ext/stomp/impl/EventBusBridge;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/ext/stomp/impl/EventBusBridge.lambda$0(Ljava/lang/String;Lio/vertx/core/eventbus/Message;)V (7)
(Lio/vertx/core/eventbus/Message;)V
invokeinterface io.vertx.core.eventbus.EventBus.consumer:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/MessageConsumer;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: StackMap locals: java.lang.String io.vertx.ext.stomp.impl.Topic$Subscription
StackMap stack:
aload 0
areturn
end local 4 7: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 8 1 connection Lio/vertx/ext/stomp/StompServerConnection;
0 8 2 frame Lio/vertx/ext/stomp/Frame;
1 8 3 address Ljava/lang/String;
3 7 4 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=3, locals=8, args_size=3
start local 0 start local 1 start local 2 0: new java.util.ArrayList
dup
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
astore 4
goto 11
StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge 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
start local 3 2: aload 3
getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
aload 1
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 11
3: aload 3
getfield io.vertx.ext.stomp.impl.Topic$Subscription.id:Ljava/lang/String;
aload 2
invokevirtual io.vertx.ext.stomp.Frame.getId:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 11
4: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
aload 3
invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
istore 5
start local 5 5: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 3
invokedynamic test(Lio/vertx/ext/stomp/impl/Topic$Subscription;)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/EventBusBridge.lambda$4(Lio/vertx/ext/stomp/impl/Topic$Subscription;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;
invokeinterface java.util.stream.Stream.findAny:()Ljava/util/Optional;
astore 6
start local 6 6: aload 6
invokevirtual java.util.Optional.isPresent:()Z
ifne 10
7: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.registry:Ljava/util/Map;
aload 3
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageConsumer
astore 7
start local 7 8: aload 7
ifnull 10
9: aload 7
invokeinterface io.vertx.core.eventbus.MessageConsumer.unregister:()V
end local 7 10: StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame io.vertx.ext.stomp.impl.Topic$Subscription java.util.Iterator int java.util.Optional
StackMap stack:
iload 5
ireturn
end local 6 end local 5 end local 3 11: StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.ext.stomp.StompServerConnection io.vertx.ext.stomp.Frame top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
12: iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 13 1 connection Lio/vertx/ext/stomp/StompServerConnection;
0 13 2 frame Lio/vertx/ext/stomp/Frame;
2 11 3 subscription Lio/vertx/ext/stomp/impl/Topic$Subscription;
5 11 5 r Z
6 11 6 any Ljava/util/Optional<Lio/vertx/ext/stomp/impl/Topic$Subscription;>;
8 10 7 consumer Lio/vertx/core/eventbus/MessageConsumer<*>;
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 start local 1 0: new java.util.ArrayList
dup
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
1: invokevirtual java.util.ArrayList.stream:()Ljava/util/stream/Stream;
2: aload 1
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/EventBusBridge.lambda$5(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: aload 0
invokedynamic accept(Lio/vertx/ext/stomp/impl/EventBusBridge;)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/ext/stomp/impl/EventBusBridge.lambda$6(Lio/vertx/ext/stomp/impl/Topic$Subscription;)V (7)
(Lio/vertx/ext/stomp/impl/Topic$Subscription;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
4: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 5 1 connection Lio/vertx/ext/stomp/StompServerConnection;
MethodParameters:
Name Flags
connection
private io.vertx.ext.stomp.Frame transform(io.vertx.core.eventbus.Message<java.lang.Object>, io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Lio/vertx/core/eventbus/Message;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Lio/vertx/ext/stomp/Frame;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=8, args_size=3
start local 0 start local 1 start local 2 0: invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
invokevirtual java.util.UUID.toString:()Ljava/lang/String;
astore 3
start local 3 1: new io.vertx.ext.stomp.Frame
dup
invokespecial io.vertx.ext.stomp.Frame.<init>:()V
astore 4
start local 4 2: aload 4
getstatic io.vertx.ext.stomp.Frame$Command.MESSAGE:Lio/vertx/ext/stomp/Frame$Command;
invokevirtual io.vertx.ext.stomp.Frame.setCommand:(Lio/vertx/ext/stomp/Frame$Command;)Lio/vertx/ext/stomp/Frame;
pop
3: aload 4
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;
4: ldc "subscription"
aload 2
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;
5: ldc "message-id"
aload 3
invokevirtual io.vertx.ext.stomp.utils.Headers.add:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
6: ldc "destination"
aload 1
invokeinterface io.vertx.core.eventbus.Message.address:()Ljava/lang/String;
invokevirtual io.vertx.ext.stomp.utils.Headers.add:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
7: astore 5
start local 5 8: ldc "auto"
aload 2
getfield io.vertx.ext.stomp.impl.Topic$Subscription.ackMode:Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
9: aload 5
ldc "ack"
aload 3
invokevirtual io.vertx.ext.stomp.utils.Headers.add:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
pop
10: StackMap locals: java.lang.String io.vertx.ext.stomp.Frame io.vertx.ext.stomp.utils.Headers
StackMap stack:
aload 1
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
ifnull 12
11: aload 5
ldc "reply-address"
aload 1
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
invokevirtual io.vertx.ext.stomp.utils.Headers.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
12: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.eventbus.Message.headers:()Lio/vertx/core/MultiMap;
invokeinterface io.vertx.core.MultiMap.iterator:()Ljava/util/Iterator;
astore 7
goto 15
StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.core.eventbus.Message io.vertx.ext.stomp.impl.Topic$Subscription java.lang.String io.vertx.ext.stomp.Frame io.vertx.ext.stomp.utils.Headers top java.util.Iterator
StackMap stack:
13: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 6
start local 6 14: aload 5
aload 6
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 6
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual io.vertx.ext.stomp.utils.Headers.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 6 15: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
16: aload 4
aload 5
invokevirtual io.vertx.ext.stomp.Frame.setHeaders:(Ljava/util/Map;)Lio/vertx/ext/stomp/Frame;
pop
17: aload 1
invokeinterface io.vertx.core.eventbus.Message.body:()Ljava/lang/Object;
astore 6
start local 6 18: aload 6
ifnull 29
19: aload 6
instanceof java.lang.String
ifeq 22
20: aload 4
aload 6
checkcast java.lang.String
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokevirtual io.vertx.ext.stomp.Frame.setBody:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/Frame;
pop
21: goto 29
StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.core.eventbus.Message io.vertx.ext.stomp.impl.Topic$Subscription java.lang.String io.vertx.ext.stomp.Frame io.vertx.ext.stomp.utils.Headers java.lang.Object
StackMap stack:
22: aload 6
instanceof io.vertx.core.buffer.Buffer
ifeq 25
23: aload 4
aload 6
checkcast io.vertx.core.buffer.Buffer
invokevirtual io.vertx.ext.stomp.Frame.setBody:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/Frame;
pop
24: goto 29
StackMap locals:
StackMap stack:
25: aload 6
instanceof io.vertx.core.json.JsonObject
ifeq 28
26: aload 4
aload 6
checkcast io.vertx.core.json.JsonObject
invokevirtual io.vertx.core.json.JsonObject.encode:()Ljava/lang/String;
invokestatic io.vertx.core.buffer.Buffer.buffer:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokevirtual io.vertx.ext.stomp.Frame.setBody:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/ext/stomp/Frame;
pop
27: goto 29
28: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Illegal body - unsupported body type: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 6
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
29: StackMap locals:
StackMap stack:
aload 6
ifnull 31
aload 4
ldc "content-length"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
ifnonnull 31
30: aload 4
ldc "content-length"
aload 4
invokevirtual io.vertx.ext.stomp.Frame.getBody:()Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
invokestatic java.lang.Integer.toString:(I)Ljava/lang/String;
invokevirtual io.vertx.ext.stomp.Frame.addHeader:(Ljava/lang/String;Ljava/lang/String;)Lio/vertx/ext/stomp/Frame;
pop
31: StackMap locals:
StackMap stack:
aload 4
areturn
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 32 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 32 1 msg Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;
0 32 2 subscription Lio/vertx/ext/stomp/impl/Topic$Subscription;
1 32 3 messageId Ljava/lang/String;
2 32 4 frame Lio/vertx/ext/stomp/Frame;
8 32 5 headers Lio/vertx/ext/stomp/utils/Headers;
14 15 6 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
18 32 6 body Ljava/lang/Object;
Signature: (Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Lio/vertx/ext/stomp/Frame;
MethodParameters:
Name Flags
msg
subscription
public 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: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokevirtual io.vertx.ext.stomp.Frame.getDestination:()Ljava/lang/String;
astore 3
start local 3 1: aload 0
iconst_1
aload 3
aload 2
invokevirtual io.vertx.ext.stomp.Frame.getBody:()Lio/vertx/core/buffer/Buffer;
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.checkMatches:(ZLjava/lang/String;Ljava/lang/Object;)Z
ifeq 8
2: aload 2
ldc "reply-address"
invokevirtual io.vertx.ext.stomp.Frame.getHeader:(Ljava/lang/String;)Ljava/lang/String;
astore 4
start local 4 3: aload 4
ifnull 6
4: aload 0
aload 3
aload 2
aload 0
aload 1
aload 3
aload 4
invokedynamic handle(Lio/vertx/ext/stomp/impl/EventBusBridge;Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;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/ext/stomp/impl/EventBusBridge.lambda$8(Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V (7)
(Lio/vertx/core/AsyncResult;)V
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.send:(Ljava/lang/String;Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)V
5: goto 15
6: StackMap locals: java.lang.String java.lang.String
StackMap stack:
aload 0
aload 3
aload 2
aconst_null
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.send:(Ljava/lang/String;Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)V
end local 4 7: goto 15
8: StackMap locals:
StackMap stack:
aload 1
ldc "Access denied"
iconst_2
anewarray java.lang.String
dup
iconst_0
ldc "destination"
aastore
dup
iconst_1
9: aload 3
aastore
10: invokestatic io.vertx.ext.stomp.utils.Headers.create:([Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
11: new java.lang.StringBuilder
dup
ldc "Access denied to "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
12: 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;
13: invokeinterface io.vertx.ext.stomp.StompServerConnection.close:()V
14: aconst_null
areturn
15: StackMap locals:
StackMap stack:
aload 0
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 16 1 connection Lio/vertx/ext/stomp/StompServerConnection;
0 16 2 frame Lio/vertx/ext/stomp/Frame;
1 16 3 address Ljava/lang/String;
3 7 4 replyAddress Ljava/lang/String;
MethodParameters:
Name Flags
connection
frame
private void send(java.lang.String, io.vertx.ext.stomp.Frame, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.eventbus.Message<java.lang.Object>>>);
descriptor: (Ljava/lang/String;Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.options:Lio/vertx/ext/stomp/BridgeOptions;
invokevirtual io.vertx.ext.stomp.BridgeOptions.isPointToPoint:()Z
ifeq 5
1: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.eventBus:()Lio/vertx/core/eventbus/EventBus;
aload 1
aload 2
invokevirtual io.vertx.ext.stomp.Frame.getBody:()Lio/vertx/core/buffer/Buffer;
2: new io.vertx.core.eventbus.DeliveryOptions
dup
invokespecial io.vertx.core.eventbus.DeliveryOptions.<init>:()V
aload 0
aload 2
invokevirtual io.vertx.ext.stomp.Frame.getHeaders:()Ljava/util/Map;
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.toMultimap:(Ljava/util/Map;)Lio/vertx/core/MultiMap;
invokevirtual io.vertx.core.eventbus.DeliveryOptions.setHeaders:(Lio/vertx/core/MultiMap;)Lio/vertx/core/eventbus/DeliveryOptions;
aload 3
3: invokeinterface io.vertx.core.eventbus.EventBus.send:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/EventBus;
pop
4: goto 8
5: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.eventBus:()Lio/vertx/core/eventbus/EventBus;
aload 1
aload 2
invokevirtual io.vertx.ext.stomp.Frame.getBody:()Lio/vertx/core/buffer/Buffer;
6: new io.vertx.core.eventbus.DeliveryOptions
dup
invokespecial io.vertx.core.eventbus.DeliveryOptions.<init>:()V
aload 0
aload 2
invokevirtual io.vertx.ext.stomp.Frame.getHeaders:()Ljava/util/Map;
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.toMultimap:(Ljava/util/Map;)Lio/vertx/core/MultiMap;
invokevirtual io.vertx.core.eventbus.DeliveryOptions.setHeaders:(Lio/vertx/core/MultiMap;)Lio/vertx/core/eventbus/DeliveryOptions;
7: invokeinterface io.vertx.core.eventbus.EventBus.publish:(Ljava/lang/String;Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryOptions;)Lio/vertx/core/eventbus/EventBus;
pop
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 9 1 address Ljava/lang/String;
0 9 2 frame Lio/vertx/ext/stomp/Frame;
0 9 3 replyHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;>;>;
Signature: (Ljava/lang/String;Lio/vertx/ext/stomp/Frame;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;>;>;)V
MethodParameters:
Name Flags
address
frame
replyHandler
private io.vertx.core.MultiMap toMultimap(java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/util/Map;)Lio/vertx/core/MultiMap;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.MultiMap.caseInsensitiveMultiMap:()Lio/vertx/core/MultiMap;
aload 1
invokeinterface io.vertx.core.MultiMap.addAll:(Ljava/util/Map;)Lio/vertx/core/MultiMap;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 1 1 headers Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/core/MultiMap;
MethodParameters:
Name Flags
headers
public boolean matches(java.lang.String, io.vertx.core.buffer.Buffer);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
iconst_0
aload 1
aload 2
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.checkMatches:(ZLjava/lang/String;Ljava/lang/Object;)Z
ifne 1
aload 0
iconst_1
aload 1
aload 2
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.checkMatches:(ZLjava/lang/String;Ljava/lang/Object;)Z
ifne 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 2 1 address Ljava/lang/String;
0 2 2 payload Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
address
payload
public boolean matches(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iconst_0
aload 1
aconst_null
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.checkMatches:(ZLjava/lang/String;Ljava/lang/Object;)Z
ifne 1
aload 0
iconst_1
aload 1
aconst_null
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.checkMatches:(ZLjava/lang/String;Ljava/lang/Object;)Z
ifne 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 2 1 address Ljava/lang/String;
MethodParameters:
Name Flags
address
private boolean regexMatches(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.expressions:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.regex.Pattern
astore 3
start local 3 1: aload 3
ifnonnull 4
2: aload 1
invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
astore 3
3: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.expressions:Ljava/util/Map;
aload 1
aload 3
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: StackMap locals: java.util.regex.Pattern
StackMap stack:
aload 3
aload 2
invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
astore 4
start local 4 5: aload 4
invokevirtual java.util.regex.Matcher.matches:()Z
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 6 1 matchRegex Ljava/lang/String;
0 6 2 address Ljava/lang/String;
1 6 3 pattern Ljava/util/regex/Pattern;
5 6 4 m Ljava/util/regex/Matcher;
MethodParameters:
Name Flags
matchRegex
address
private boolean checkMatches(boolean, java.lang.String, java.lang.Object);
descriptor: (ZLjava/lang/String;Ljava/lang/Object;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=10, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 1
ifeq 1
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.options:Lio/vertx/ext/stomp/BridgeOptions;
invokevirtual io.vertx.ext.stomp.BridgeOptions.getInboundPermitteds:()Ljava/util/List;
goto 2
StackMap locals:
StackMap stack:
1: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.options:Lio/vertx/ext/stomp/BridgeOptions;
invokevirtual io.vertx.ext.stomp.BridgeOptions.getOutboundPermitteds:()Ljava/util/List;
StackMap locals:
StackMap stack: java.util.List
2: astore 4
start local 4 3: aload 4
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 6
goto 18
StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge int java.lang.String java.lang.Object java.util.List top java.util.Iterator
StackMap stack:
4: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.ext.bridge.PermittedOptions
astore 5
start local 5 5: aload 5
invokevirtual io.vertx.ext.bridge.PermittedOptions.getAddress:()Ljava/lang/String;
astore 7
start local 7 6: aload 7
ifnonnull 9
7: aload 5
invokevirtual io.vertx.ext.bridge.PermittedOptions.getAddressRegex:()Ljava/lang/String;
astore 8
start local 8 8: goto 10
end local 8 9: StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge int java.lang.String java.lang.Object java.util.List io.vertx.ext.bridge.PermittedOptions java.util.Iterator java.lang.String
StackMap stack:
aconst_null
astore 8
start local 8 10: StackMap locals: java.lang.String
StackMap stack:
aload 7
ifnonnull 15
11: aload 8
ifnull 12
aload 0
aload 8
aload 2
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.regexMatches:(Ljava/lang/String;Ljava/lang/String;)Z
ifne 12
iconst_0
goto 13
StackMap locals:
StackMap stack:
12: iconst_1
StackMap locals:
StackMap stack: int
13: istore 9
start local 9 14: goto 16
end local 9 15: StackMap locals:
StackMap stack:
aload 7
aload 2
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
istore 9
start local 9 16: StackMap locals: int
StackMap stack:
iload 9
ifeq 18
17: aload 0
aload 5
invokevirtual io.vertx.ext.bridge.PermittedOptions.getMatch:()Lio/vertx/core/json/JsonObject;
aload 3
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.structureMatches:(Lio/vertx/core/json/JsonObject;Ljava/lang/Object;)Z
ireturn
end local 9 end local 8 end local 7 end local 5 18: StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge int java.lang.String java.lang.Object java.util.List top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
19: iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 20 1 inbound Z
0 20 2 address Ljava/lang/String;
0 20 3 body Ljava/lang/Object;
3 20 4 matches Ljava/util/List<Lio/vertx/ext/bridge/PermittedOptions;>;
5 18 5 matchHolder Lio/vertx/ext/bridge/PermittedOptions;
6 18 7 matchAddress Ljava/lang/String;
8 9 8 matchRegex Ljava/lang/String;
10 18 8 matchRegex Ljava/lang/String;
14 15 9 addressOK Z
16 18 9 addressOK Z
MethodParameters:
Name Flags
inbound
address
body
private boolean structureMatches(io.vertx.core.json.JsonObject, java.lang.Object);
descriptor: (Lio/vertx/core/json/JsonObject;Ljava/lang/Object;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=8, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnull 1
aload 2
ifnonnull 2
1: StackMap locals:
StackMap stack:
iconst_1
ireturn
2: StackMap locals:
StackMap stack:
aload 2
instanceof io.vertx.core.json.JsonObject
ifeq 5
3: aload 2
checkcast io.vertx.core.json.JsonObject
astore 3
start local 3 4: goto 12
end local 3 StackMap locals:
StackMap stack:
5: aload 2
instanceof io.vertx.core.buffer.Buffer
ifeq 8
6: new io.vertx.core.json.JsonObject
dup
aload 2
checkcast io.vertx.core.buffer.Buffer
ldc "UTF-8"
invokeinterface io.vertx.core.buffer.Buffer.toString:(Ljava/lang/String;)Ljava/lang/String;
invokespecial io.vertx.core.json.JsonObject.<init>:(Ljava/lang/String;)V
astore 3
start local 3 7: goto 12
end local 3 StackMap locals:
StackMap stack:
8: aload 2
instanceof java.lang.String
ifeq 11
9: new io.vertx.core.json.JsonObject
dup
aload 2
checkcast java.lang.String
invokespecial io.vertx.core.json.JsonObject.<init>:(Ljava/lang/String;)V
astore 3
start local 3 10: goto 12
end local 3 11: StackMap locals:
StackMap stack:
iconst_0
ireturn
start local 3 12: StackMap locals: io.vertx.core.json.JsonObject
StackMap stack:
aload 1
invokevirtual io.vertx.core.json.JsonObject.fieldNames:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 21
StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.core.json.JsonObject java.lang.Object io.vertx.core.json.JsonObject top java.util.Iterator
StackMap stack:
13: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 4
start local 4 14: aload 1
aload 4
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;)Ljava/lang/Object;
astore 6
start local 6 15: aload 3
aload 4
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;)Ljava/lang/Object;
astore 7
start local 7 16: aload 6
instanceof io.vertx.core.json.JsonObject
ifeq 19
17: aload 0
aload 6
checkcast io.vertx.core.json.JsonObject
aload 7
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.structureMatches:(Lio/vertx/core/json/JsonObject;Ljava/lang/Object;)Z
ifne 21
18: iconst_0
ireturn
19: StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.core.json.JsonObject java.lang.Object io.vertx.core.json.JsonObject java.lang.String java.util.Iterator java.lang.Object java.lang.Object
StackMap stack:
aload 1
aload 4
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;)Ljava/lang/Object;
aload 3
aload 4
invokevirtual io.vertx.core.json.JsonObject.getValue:(Ljava/lang/String;)Ljava/lang/Object;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifne 21
20: iconst_0
ireturn
end local 7 end local 6 end local 4 21: StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.core.json.JsonObject java.lang.Object io.vertx.core.json.JsonObject top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
22: iconst_1
ireturn
end local 3 23: StackMap locals: io.vertx.ext.stomp.impl.EventBusBridge io.vertx.core.json.JsonObject java.lang.Object
StackMap stack: java.lang.Exception
pop
24: iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 25 1 match Lio/vertx/core/json/JsonObject;
0 25 2 body Ljava/lang/Object;
4 5 3 object Lio/vertx/core/json/JsonObject;
7 8 3 object Lio/vertx/core/json/JsonObject;
10 11 3 object Lio/vertx/core/json/JsonObject;
12 23 3 object Lio/vertx/core/json/JsonObject;
14 21 4 fieldName Ljava/lang/String;
15 21 6 mv Ljava/lang/Object;
16 21 7 bv Ljava/lang/Object;
Exception table:
from to target type
2 11 23 Class java.lang.Exception
12 18 23 Class java.lang.Exception
19 20 23 Class java.lang.Exception
21 22 23 Class java.lang.Exception
MethodParameters:
Name Flags
match
body
private void lambda$0(java.lang.String, io.vertx.core.eventbus.Message);
descriptor: (Ljava/lang/String;Lio/vertx/core/eventbus/Message;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 2 0: aload 0
iconst_0
aload 1
aload 2
invokeinterface io.vertx.core.eventbus.Message.body:()Ljava/lang/Object;
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.checkMatches:(ZLjava/lang/String;Ljava/lang/Object;)Z
ifne 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.options:Lio/vertx/ext/stomp/BridgeOptions;
invokevirtual io.vertx.ext.stomp.BridgeOptions.isPointToPoint:()Z
ifeq 8
3: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 1
invokedynamic test(Ljava/lang/String;)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/EventBusBridge.lambda$1(Ljava/lang/String;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;
invokeinterface java.util.stream.Stream.findAny:()Ljava/util/Optional;
astore 3
start local 3 4: aload 3
invokevirtual java.util.Optional.isPresent:()Z
ifeq 9
5: aload 0
aload 2
aload 3
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast io.vertx.ext.stomp.impl.Topic$Subscription
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.transform:(Lio/vertx/core/eventbus/Message;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Lio/vertx/ext/stomp/Frame;
astore 4
start local 4 6: aload 3
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast io.vertx.ext.stomp.impl.Topic$Subscription
getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
aload 4
invokeinterface io.vertx.ext.stomp.StompServerConnection.write:(Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompServerConnection;
pop
end local 4 end local 3 7: goto 9
8: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 1
invokedynamic test(Ljava/lang/String;)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/EventBusBridge.lambda$2(Ljava/lang/String;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;
aload 0
aload 2
invokedynamic accept(Lio/vertx/ext/stomp/impl/EventBusBridge;Lio/vertx/core/eventbus/Message;)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/ext/stomp/impl/EventBusBridge.lambda$3(Lio/vertx/core/eventbus/Message;Lio/vertx/ext/stomp/impl/Topic$Subscription;)V (7)
(Lio/vertx/ext/stomp/impl/Topic$Subscription;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
9: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 10 2 msg Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;
4 7 3 chosen Ljava/util/Optional<Lio/vertx/ext/stomp/impl/Topic$Subscription;>;
6 7 4 stompFrame Lio/vertx/ext/stomp/Frame;
private static boolean lambda$4(io.vertx.ext.stomp.impl.Topic$Subscription, io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Lio/vertx/ext/stomp/impl/Topic$Subscription;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 0: aload 1
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
aload 0
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lio/vertx/ext/stomp/impl/Topic$Subscription;
private static boolean lambda$5(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 0: aload 1
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 LocalVariableTable:
Start End Slot Name Signature
0 1 1 subscription Lio/vertx/ext/stomp/impl/Topic$Subscription;
private void lambda$6(io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Lio/vertx/ext/stomp/impl/Topic$Subscription;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
aload 1
invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
pop
1: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 1
invokedynamic test(Lio/vertx/ext/stomp/impl/Topic$Subscription;)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/EventBusBridge.lambda$7(Lio/vertx/ext/stomp/impl/Topic$Subscription;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: invokeinterface java.util.stream.Stream.findAny:()Ljava/util/Optional;
3: astore 2
start local 2 4: aload 2
invokevirtual java.util.Optional.isPresent:()Z
ifne 8
5: aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.registry:Ljava/util/Map;
aload 1
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.eventbus.MessageConsumer
astore 3
start local 3 6: aload 3
ifnull 8
7: aload 3
invokeinterface io.vertx.core.eventbus.MessageConsumer.unregister:()V
end local 3 end local 2 8: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 9 1 s Lio/vertx/ext/stomp/impl/Topic$Subscription;
4 8 2 any Ljava/util/Optional<Lio/vertx/ext/stomp/impl/Topic$Subscription;>;
6 8 3 consumer Lio/vertx/core/eventbus/MessageConsumer<*>;
private void lambda$8(io.vertx.ext.stomp.StompServerConnection, java.lang.String, java.lang.String, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Ljava/lang/String;Lio/vertx/core/AsyncResult;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=7, args_size=5
start local 0 start local 4 0: aload 4
invokeinterface io.vertx.core.AsyncResult.failed:()Z
ifeq 9
1: aload 4
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
astore 5
start local 5 2: aload 1
ldc "Message dispatch error"
iconst_4
anewarray java.lang.String
dup
iconst_0
ldc "destination"
aastore
dup
iconst_1
3: aload 2
aastore
dup
iconst_2
ldc "reply-address"
aastore
dup
iconst_3
aload 3
aastore
4: invokestatic io.vertx.ext.stomp.utils.Headers.create:([Ljava/lang/String;)Lio/vertx/ext/stomp/utils/Headers;
5: aload 5
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
6: 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;
7: invokeinterface io.vertx.ext.stomp.StompServerConnection.close:()V
end local 5 8: goto 16
9: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.ext.stomp.impl.EventBusBridge.subscriptions:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
10: aload 1
aload 3
invokedynamic test(Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;)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/EventBusBridge.lambda$9(Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;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;
11: invokeinterface java.util.stream.Stream.findFirst:()Ljava/util/Optional;
12: astore 5
start local 5 13: aload 5
invokevirtual java.util.Optional.isPresent:()Z
ifeq 16
14: aload 0
aload 4
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.core.eventbus.Message
aload 5
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast io.vertx.ext.stomp.impl.Topic$Subscription
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.transform:(Lio/vertx/core/eventbus/Message;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Lio/vertx/ext/stomp/Frame;
astore 6
start local 6 15: aload 5
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast io.vertx.ext.stomp.impl.Topic$Subscription
getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
aload 6
invokeinterface io.vertx.ext.stomp.StompServerConnection.write:(Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompServerConnection;
pop
end local 6 end local 5 16: StackMap locals:
StackMap stack:
return
end local 4 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 17 4 res Lio/vertx/core/AsyncResult<Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;>;
2 8 5 cause Ljava/lang/Throwable;
13 16 5 subscription Ljava/util/Optional<Lio/vertx/ext/stomp/impl/Topic$Subscription;>;
15 16 6 stompFrame Lio/vertx/ext/stomp/Frame;
private static boolean lambda$1(java.lang.String, io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Ljava/lang/String;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 0: aload 1
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lio/vertx/ext/stomp/impl/Topic$Subscription;
private static boolean lambda$2(java.lang.String, io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Ljava/lang/String;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 0: aload 1
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lio/vertx/ext/stomp/impl/Topic$Subscription;
private void lambda$3(io.vertx.core.eventbus.Message, io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Lio/vertx/core/eventbus/Message;Lio/vertx/ext/stomp/impl/Topic$Subscription;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 2 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.ext.stomp.impl.EventBusBridge.transform:(Lio/vertx/core/eventbus/Message;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Lio/vertx/ext/stomp/Frame;
astore 3
start local 3 1: aload 2
getfield io.vertx.ext.stomp.impl.Topic$Subscription.connection:Lio/vertx/ext/stomp/StompServerConnection;
aload 3
invokeinterface io.vertx.ext.stomp.StompServerConnection.write:(Lio/vertx/ext/stomp/Frame;)Lio/vertx/ext/stomp/StompServerConnection;
pop
end local 3 2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/stomp/impl/EventBusBridge;
0 3 2 s Lio/vertx/ext/stomp/impl/Topic$Subscription;
1 2 3 stompFrame Lio/vertx/ext/stomp/Frame;
private static boolean lambda$7(io.vertx.ext.stomp.impl.Topic$Subscription, io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Lio/vertx/ext/stomp/impl/Topic$Subscription;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 0: aload 1
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
aload 0
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s2 Lio/vertx/ext/stomp/impl/Topic$Subscription;
private static boolean lambda$9(io.vertx.ext.stomp.StompServerConnection, java.lang.String, io.vertx.ext.stomp.impl.Topic$Subscription);
descriptor: (Lio/vertx/ext/stomp/StompServerConnection;Ljava/lang/String;Lio/vertx/ext/stomp/impl/Topic$Subscription;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 2
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
ifeq 1
aload 2
getfield io.vertx.ext.stomp.impl.Topic$Subscription.destination:Ljava/lang/String;
aload 1
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ireturn
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 s Lio/vertx/ext/stomp/impl/Topic$Subscription;
}
SourceFile: "EventBusBridge.java"
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
public abstract Entry = java.util.Map$Entry of java.util.Map