public class io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext<T> implements io.vertx.core.eventbus.DeliveryContext<T>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext
super_class: java.lang.Object
{
public final io.vertx.core.eventbus.impl.MessageImpl message;
descriptor: Lio/vertx/core/eventbus/impl/MessageImpl;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final io.vertx.core.eventbus.DeliveryOptions options;
descriptor: Lio/vertx/core/eventbus/DeliveryOptions;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final java.util.Iterator<io.vertx.core.Handler<io.vertx.core.eventbus.DeliveryContext>> iter;
descriptor: Ljava/util/Iterator;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Ljava/util/Iterator<Lio/vertx/core/Handler<Lio/vertx/core/eventbus/DeliveryContext;>;>;
private final io.vertx.core.eventbus.impl.HandlerRegistration<T> handlerRegistration;
descriptor: Lio/vertx/core/eventbus/impl/HandlerRegistration;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/eventbus/impl/HandlerRegistration<TT;>;
private final io.vertx.core.eventbus.impl.MessageImpl replierMessage;
descriptor: Lio/vertx/core/eventbus/impl/MessageImpl;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
final io.vertx.core.eventbus.impl.EventBusImpl this$0;
descriptor: Lio/vertx/core/eventbus/impl/EventBusImpl;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private void <init>(io.vertx.core.eventbus.impl.MessageImpl, io.vertx.core.eventbus.DeliveryOptions, io.vertx.core.eventbus.impl.HandlerRegistration<T>);
descriptor: (Lio/vertx/core/eventbus/impl/EventBusImpl;Lio/vertx/core/eventbus/impl/MessageImpl;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/eventbus/impl/HandlerRegistration;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=5
start local 0 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
aload 4
aconst_null
invokespecial io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.<init>:(Lio/vertx/core/eventbus/impl/EventBusImpl;Lio/vertx/core/eventbus/impl/MessageImpl;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/eventbus/impl/HandlerRegistration;Lio/vertx/core/eventbus/impl/MessageImpl;)V
1: return
end local 4 end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext<TT;>;
0 2 2 message Lio/vertx/core/eventbus/impl/MessageImpl;
0 2 3 options Lio/vertx/core/eventbus/DeliveryOptions;
0 2 4 handlerRegistration Lio/vertx/core/eventbus/impl/HandlerRegistration<TT;>;
Signature: (Lio/vertx/core/eventbus/impl/MessageImpl;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/eventbus/impl/HandlerRegistration<TT;>;)V
MethodParameters:
Name Flags
this$0 final
message
options
handlerRegistration
private void <init>(io.vertx.core.eventbus.impl.MessageImpl, io.vertx.core.eventbus.DeliveryOptions, io.vertx.core.eventbus.impl.HandlerRegistration<T>, io.vertx.core.eventbus.impl.MessageImpl);
descriptor: (Lio/vertx/core/eventbus/impl/EventBusImpl;Lio/vertx/core/eventbus/impl/MessageImpl;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/eventbus/impl/HandlerRegistration;Lio/vertx/core/eventbus/impl/MessageImpl;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=6, args_size=6
start local 0 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 1
putfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/EventBusImpl;
aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 2
putfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
2: aload 0
aload 3
putfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.options:Lio/vertx/core/eventbus/DeliveryOptions;
3: aload 0
aload 4
putfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.handlerRegistration:Lio/vertx/core/eventbus/impl/HandlerRegistration;
4: aload 0
aload 1
getfield io.vertx.core.eventbus.impl.EventBusImpl.sendInterceptors:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
putfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.iter:Ljava/util/Iterator;
5: aload 0
aload 5
putfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.replierMessage:Lio/vertx/core/eventbus/impl/MessageImpl;
6: return
end local 5 end local 4 end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext<TT;>;
0 7 2 message Lio/vertx/core/eventbus/impl/MessageImpl;
0 7 3 options Lio/vertx/core/eventbus/DeliveryOptions;
0 7 4 handlerRegistration Lio/vertx/core/eventbus/impl/HandlerRegistration<TT;>;
0 7 5 replierMessage Lio/vertx/core/eventbus/impl/MessageImpl;
Signature: (Lio/vertx/core/eventbus/impl/MessageImpl;Lio/vertx/core/eventbus/DeliveryOptions;Lio/vertx/core/eventbus/impl/HandlerRegistration<TT;>;Lio/vertx/core/eventbus/impl/MessageImpl;)V
MethodParameters:
Name Flags
this$0 final
message
options
handlerRegistration
replierMessage
public io.vertx.core.eventbus.Message<T> message();
descriptor: ()Lio/vertx/core/eventbus/Message;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext<TT;>;
Signature: ()Lio/vertx/core/eventbus/Message<TT;>;
public void next();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.iter:Ljava/util/Iterator;
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 10
1: aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.iter:Ljava/util/Iterator;
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.core.Handler
astore 1
start local 1 2: aload 1
ifnull 5
3: aload 1
aload 0
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: goto 14
5: StackMap locals: io.vertx.core.Handler
StackMap stack:
aload 0
invokevirtual io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.next:()V
6: goto 14
StackMap locals:
StackMap stack: java.lang.Throwable
7: astore 2
start local 2 8: getstatic io.vertx.core.eventbus.impl.EventBusImpl.log:Lio/vertx/core/logging/Logger;
ldc "Failure in interceptor"
aload 2
invokevirtual io.vertx.core.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 2 end local 1 9: goto 14
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.replierMessage:Lio/vertx/core/eventbus/impl/MessageImpl;
ifnonnull 13
11: aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/EventBusImpl;
aload 0
invokevirtual io.vertx.core.eventbus.impl.EventBusImpl.sendOrPub:(Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext;)V
12: goto 14
13: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/EventBusImpl;
aload 0
aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.replierMessage:Lio/vertx/core/eventbus/impl/MessageImpl;
invokevirtual io.vertx.core.eventbus.impl.EventBusImpl.sendReply:(Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext;Lio/vertx/core/eventbus/impl/MessageImpl;)V
14: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext<TT;>;
2 9 1 handler Lio/vertx/core/Handler<Lio/vertx/core/eventbus/DeliveryContext;>;
8 9 2 t Ljava/lang/Throwable;
Exception table:
from to target type
2 6 7 Class java.lang.Throwable
public boolean send();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
invokevirtual io.vertx.core.eventbus.impl.MessageImpl.isSend:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext<TT;>;
public java.lang.Object body();
descriptor: ()Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
getfield io.vertx.core.eventbus.impl.MessageImpl.sentBody:Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/eventbus/impl/EventBusImpl$OutboundDeliveryContext<TT;>;
}
Signature: <T:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryContext<TT;>;
SourceFile: "EventBusImpl.java"
NestHost: io.vertx.core.eventbus.impl.EventBusImpl
InnerClasses:
protected OutboundDeliveryContext = io.vertx.core.eventbus.impl.EventBusImpl$OutboundDeliveryContext of io.vertx.core.eventbus.impl.EventBusImpl