public class io.vertx.ext.shell.command.base.BusTail extends io.vertx.ext.shell.command.AnnotatedCommand
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.shell.command.base.BusTail
super_class: io.vertx.ext.shell.command.AnnotatedCommand
{
private java.util.List<java.lang.String> addresses;
descriptor: Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/List<Ljava/lang/String;>;
private boolean verbose;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean local;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.vertx.ext.shell.command.AnnotatedCommand.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/shell/command/base/BusTail;
public void setAddresses(java.util.List<java.lang.String>);
descriptor: (Ljava/util/List;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.ext.shell.command.base.BusTail.addresses:Ljava/util/List;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/shell/command/base/BusTail;
0 2 1 addresses Ljava/util/List<Ljava/lang/String;>;
Signature: (Ljava/util/List<Ljava/lang/String;>;)V
RuntimeVisibleAnnotations:
io.vertx.core.cli.annotations.Argument(index = 0, argName = "address")
io.vertx.core.cli.annotations.Description(value = "the bus address destination")
MethodParameters:
Name Flags
addresses
public void setVerbose(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield io.vertx.ext.shell.command.base.BusTail.verbose:Z
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/shell/command/base/BusTail;
0 2 1 verbose Z
RuntimeVisibleAnnotations:
io.vertx.core.cli.annotations.Option(longName = "verbose", flag = true)
io.vertx.core.cli.annotations.Description(value = "verbose output")
MethodParameters:
Name Flags
verbose
public void setLocal(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield io.vertx.ext.shell.command.base.BusTail.local:Z
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/shell/command/base/BusTail;
0 2 1 local Z
RuntimeVisibleAnnotations:
io.vertx.core.cli.annotations.Option(longName = "local", flag = true)
io.vertx.core.cli.annotations.Description(value = "subscribe to a local address")
MethodParameters:
Name Flags
local
public void process(io.vertx.ext.shell.command.CommandProcess);
descriptor: (Lio/vertx/ext/shell/command/CommandProcess;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.ext.shell.command.CommandProcess.vertx:()Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.eventBus:()Lio/vertx/core/eventbus/EventBus;
astore 2
start local 2 1: aload 0
getfield io.vertx.ext.shell.command.base.BusTail.addresses:Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
aload 0
aload 1
aload 2
invokedynamic apply(Lio/vertx/ext/shell/command/base/BusTail;Lio/vertx/ext/shell/command/CommandProcess;Lio/vertx/core/eventbus/EventBus;)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/shell/command/base/BusTail.lambda$0(Lio/vertx/ext/shell/command/CommandProcess;Lio/vertx/core/eventbus/EventBus;Ljava/lang/String;)Lio/vertx/core/eventbus/MessageConsumer; (7)
(Ljava/lang/String;)Lio/vertx/core/eventbus/MessageConsumer;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
2: 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
3: astore 3
start local 3 4: aload 1
aload 1
invokedynamic handle(Lio/vertx/ext/shell/command/CommandProcess;)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/shell/command/base/BusTail.lambda$2(Lio/vertx/ext/shell/command/CommandProcess;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.ext.shell.command.CommandProcess.interruptHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/shell/command/CommandProcess;
pop
5: aload 1
aload 3
invokedynamic handle(Ljava/util/List;)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/shell/command/base/BusTail.lambda$3(Ljava/util/List;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.ext.shell.command.CommandProcess.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/ext/shell/command/CommandProcess;
pop
6: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/ext/shell/command/base/BusTail;
0 7 1 process Lio/vertx/ext/shell/command/CommandProcess;
1 7 2 eb Lio/vertx/core/eventbus/EventBus;
4 7 3 consumers Ljava/util/List<Lio/vertx/core/eventbus/MessageConsumer<Ljava/lang/Object;>;>;
MethodParameters:
Name Flags
process
private io.vertx.core.eventbus.MessageConsumer lambda$0(io.vertx.ext.shell.command.CommandProcess, io.vertx.core.eventbus.EventBus, java.lang.String);
descriptor: (Lio/vertx/ext/shell/command/CommandProcess;Lio/vertx/core/eventbus/EventBus;Ljava/lang/String;)Lio/vertx/core/eventbus/MessageConsumer;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 3 0: aload 0
aload 1
aload 3
invokedynamic handle(Lio/vertx/ext/shell/command/base/BusTail;Lio/vertx/ext/shell/command/CommandProcess;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/shell/command/base/BusTail.lambda$1(Lio/vertx/ext/shell/command/CommandProcess;Ljava/lang/String;Lio/vertx/core/eventbus/Message;)V (7)
(Lio/vertx/core/eventbus/Message;)V
astore 4
start local 4 1: aload 0
getfield io.vertx.ext.shell.command.base.BusTail.local:Z
ifeq 2
aload 2
aload 3
aload 4
invokeinterface io.vertx.core.eventbus.EventBus.localConsumer:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/MessageConsumer;
goto 3
StackMap locals: io.vertx.core.Handler
StackMap stack:
2: aload 2
aload 3
aload 4
invokeinterface io.vertx.core.eventbus.EventBus.consumer:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/core/eventbus/MessageConsumer;
StackMap locals:
StackMap stack: io.vertx.core.eventbus.MessageConsumer
3: areturn
end local 4 end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/shell/command/base/BusTail;
0 4 3 address Ljava/lang/String;
1 4 4 handler Lio/vertx/core/Handler<Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;>;
private static void lambda$2(io.vertx.ext.shell.command.CommandProcess, java.lang.Void);
descriptor: (Lio/vertx/ext/shell/command/CommandProcess;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface io.vertx.ext.shell.command.CommandProcess.end:()V
1: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 done Ljava/lang/Void;
private static void lambda$3(java.util.List, java.lang.Void);
descriptor: (Ljava/util/List;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
invokedynamic accept()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/core/eventbus/MessageConsumer.unregister()V (9 itf)
(Lio/vertx/core/eventbus/MessageConsumer;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 done Ljava/lang/Void;
private void lambda$1(io.vertx.ext.shell.command.CommandProcess, java.lang.String, io.vertx.core.eventbus.Message);
descriptor: (Lio/vertx/ext/shell/command/CommandProcess;Ljava/lang/String;Lio/vertx/core/eventbus/Message;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=9, args_size=4
start local 0 start local 3 0: aload 3
invokeinterface io.vertx.core.eventbus.Message.body:()Ljava/lang/Object;
astore 4
start local 4 1: aload 4
instanceof io.vertx.core.buffer.Buffer
ifeq 4
2: aload 4
checkcast io.vertx.core.buffer.Buffer
invokeinterface io.vertx.core.buffer.Buffer.getBytes:()[B
invokestatic io.netty.util.internal.StringUtil.toHexString:([B)Ljava/lang/String;
astore 5
start local 5 3: goto 5
end local 5 4: StackMap locals: java.lang.Object
StackMap stack:
aload 4
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
astore 5
start local 5 5: StackMap locals: java.lang.String
StackMap stack:
aload 0
getfield io.vertx.ext.shell.command.base.BusTail.verbose:Z
ifeq 15
6: aload 1
new java.lang.StringBuilder
dup
aload 2
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc ":"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "\n"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.ext.shell.command.CommandProcess.write:(Ljava/lang/String;)Lio/vertx/ext/shell/command/CommandProcess;
pop
7: aload 1
new java.lang.StringBuilder
dup
ldc "Reply address: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokeinterface io.vertx.core.eventbus.Message.replyAddress:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "\n"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.ext.shell.command.CommandProcess.write:(Ljava/lang/String;)Lio/vertx/ext/shell/command/CommandProcess;
pop
8: aload 3
invokeinterface io.vertx.core.eventbus.Message.headers:()Lio/vertx/core/MultiMap;
astore 6
start local 6 9: aload 6
invokeinterface io.vertx.core.MultiMap.names:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 8
goto 12
StackMap locals: io.vertx.ext.shell.command.base.BusTail io.vertx.ext.shell.command.CommandProcess java.lang.String io.vertx.core.eventbus.Message java.lang.Object java.lang.String io.vertx.core.MultiMap top java.util.Iterator
StackMap stack:
10: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 7
start local 7 11: aload 1
new java.lang.StringBuilder
dup
ldc "Header "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ":"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 6
aload 7
invokeinterface io.vertx.core.MultiMap.getAll:(Ljava/lang/String;)Ljava/util/List;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc "\n"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.ext.shell.command.CommandProcess.write:(Ljava/lang/String;)Lio/vertx/ext/shell/command/CommandProcess;
pop
end local 7 12: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
13: aload 1
new java.lang.StringBuilder
dup
aload 5
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc "\n"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.ext.shell.command.CommandProcess.write:(Ljava/lang/String;)Lio/vertx/ext/shell/command/CommandProcess;
pop
end local 6 14: goto 16
15: StackMap locals: io.vertx.ext.shell.command.base.BusTail io.vertx.ext.shell.command.CommandProcess java.lang.String io.vertx.core.eventbus.Message java.lang.Object java.lang.String
StackMap stack:
aload 1
new java.lang.StringBuilder
dup
aload 2
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc ":"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 5
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "\n"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface io.vertx.ext.shell.command.CommandProcess.write:(Ljava/lang/String;)Lio/vertx/ext/shell/command/CommandProcess;
pop
end local 5 end local 4 16: StackMap locals:
StackMap stack:
return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lio/vertx/ext/shell/command/base/BusTail;
0 17 3 msg Lio/vertx/core/eventbus/Message<Ljava/lang/Object;>;
1 16 4 body Ljava/lang/Object;
3 4 5 bodyString Ljava/lang/String;
5 16 5 bodyString Ljava/lang/String;
9 14 6 headers Lio/vertx/core/MultiMap;
11 12 7 header Ljava/lang/String;
}
SourceFile: "BusTail.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
RuntimeVisibleAnnotations:
io.vertx.core.cli.annotations.Name(value = "bus-tail")
io.vertx.core.cli.annotations.Summary(value = "Subscribe to one or several event bus address and logs received messages on the console")