class io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext implements io.vertx.core.eventbus.DeliveryContext<T>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext
super_class: java.lang.Object
{
private final io.vertx.core.eventbus.impl.MessageImpl<?, T> message;
descriptor: Lio/vertx/core/eventbus/impl/MessageImpl;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/eventbus/impl/MessageImpl<*TT;>;
private final java.util.Iterator<io.vertx.core.Handler<io.vertx.core.eventbus.DeliveryContext>> iter;
descriptor: Ljava/util/Iterator;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Iterator<Lio/vertx/core/Handler<Lio/vertx/core/eventbus/DeliveryContext;>;>;
private final io.vertx.core.Handler<io.vertx.core.eventbus.Message<T>> handler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/Handler<Lio/vertx/core/eventbus/Message<TT;>;>;
private final io.vertx.core.impl.ContextInternal context;
descriptor: Lio/vertx/core/impl/ContextInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
final io.vertx.core.eventbus.impl.HandlerRegistration this$0;
descriptor: Lio/vertx/core/eventbus/impl/HandlerRegistration;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private void <init>(io.vertx.core.eventbus.impl.MessageImpl<?, T>, io.vertx.core.Handler<io.vertx.core.eventbus.Message<T>>, io.vertx.core.impl.ContextInternal);
descriptor: (Lio/vertx/core/eventbus/impl/HandlerRegistration;Lio/vertx/core/eventbus/impl/MessageImpl;Lio/vertx/core/Handler;Lio/vertx/core/impl/ContextInternal;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=5, args_size=5
start local 0 start local 2 start local 3 start local 4 0: aload 0
aload 1
putfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/HandlerRegistration;
aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 2
putfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
2: aload 0
aload 3
putfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.handler:Lio/vertx/core/Handler;
3: aload 0
aload 2
getfield io.vertx.core.eventbus.impl.MessageImpl.bus:Lio/vertx/core/eventbus/impl/EventBusImpl;
invokevirtual io.vertx.core.eventbus.impl.EventBusImpl.receiveInterceptors:()Ljava/util/Iterator;
putfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.iter:Ljava/util/Iterator;
4: aload 0
aload 4
putfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.context:Lio/vertx/core/impl/ContextInternal;
5: return
end local 4 end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/eventbus/impl/HandlerRegistration$InboundDeliveryContext;
0 6 2 message Lio/vertx/core/eventbus/impl/MessageImpl<*TT;>;
0 6 3 handler Lio/vertx/core/Handler<Lio/vertx/core/eventbus/Message<TT;>;>;
0 6 4 context Lio/vertx/core/impl/ContextInternal;
Signature: (Lio/vertx/core/eventbus/impl/MessageImpl<*TT;>;Lio/vertx/core/Handler<Lio/vertx/core/eventbus/Message<TT;>;>;Lio/vertx/core/impl/ContextInternal;)V
MethodParameters:
Name Flags
this$0 final
message
handler
context
void dispatch();
descriptor: ()V
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.next:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/eventbus/impl/HandlerRegistration$InboundDeliveryContext;
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.HandlerRegistration$InboundDeliveryContext.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/HandlerRegistration$InboundDeliveryContext;
Signature: ()Lio/vertx/core/eventbus/Message<TT;>;
public void next();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=4, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.iter:Ljava/util/Iterator;
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 10
1: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.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 24
5: StackMap locals: io.vertx.core.Handler
StackMap stack:
aload 0
invokevirtual io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.next:()V
end local 1 6: goto 24
StackMap locals: io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext
StackMap stack: java.lang.Throwable
7: astore 1
start local 1 8: getstatic io.vertx.core.eventbus.impl.HandlerRegistration.log:Lio/vertx/core/impl/logging/Logger;
ldc "Failure in interceptor"
aload 1
invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
end local 1 9: goto 24
10: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/HandlerRegistration;
getfield io.vertx.core.eventbus.impl.HandlerRegistration.metric:Ljava/lang/Object;
astore 1
start local 1 11: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.context:Lio/vertx/core/impl/ContextInternal;
invokeinterface io.vertx.core.impl.ContextInternal.tracer:()Lio/vertx/core/spi/tracing/VertxTracer;
astore 2
start local 2 12: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/HandlerRegistration;
getfield io.vertx.core.eventbus.impl.HandlerRegistration.bus:Lio/vertx/core/eventbus/impl/EventBusImpl;
getfield io.vertx.core.eventbus.impl.EventBusImpl.metrics:Lio/vertx/core/spi/metrics/EventBusMetrics;
ifnull 14
13: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/HandlerRegistration;
getfield io.vertx.core.eventbus.impl.HandlerRegistration.bus:Lio/vertx/core/eventbus/impl/EventBusImpl;
getfield io.vertx.core.eventbus.impl.EventBusImpl.metrics:Lio/vertx/core/spi/metrics/EventBusMetrics;
aload 1
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
invokevirtual io.vertx.core.eventbus.impl.MessageImpl.isLocal:()Z
invokeinterface io.vertx.core.spi.metrics.EventBusMetrics.messageDelivered:(Ljava/lang/Object;Z)V
14: StackMap locals: java.lang.Object io.vertx.core.spi.tracing.VertxTracer
StackMap stack:
aload 2
ifnull 23
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/HandlerRegistration;
getfield io.vertx.core.eventbus.impl.HandlerRegistration.src:Z
ifne 23
15: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
aload 2
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.context:Lio/vertx/core/impl/ContextInternal;
getstatic io.vertx.core.spi.tracing.SpanKind.RPC:Lio/vertx/core/spi/tracing/SpanKind;
getstatic io.vertx.core.tracing.TracingPolicy.PROPAGATE:Lio/vertx/core/tracing/TracingPolicy;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
invokevirtual io.vertx.core.eventbus.impl.MessageImpl.isSend:()Z
ifeq 16
ldc "send"
goto 17
StackMap locals: io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext java.lang.Object io.vertx.core.spi.tracing.VertxTracer
StackMap stack: io.vertx.core.eventbus.impl.MessageImpl io.vertx.core.spi.tracing.VertxTracer io.vertx.core.impl.ContextInternal io.vertx.core.spi.tracing.SpanKind io.vertx.core.tracing.TracingPolicy io.vertx.core.eventbus.impl.MessageImpl
16: ldc "publish"
StackMap locals: io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext java.lang.Object io.vertx.core.spi.tracing.VertxTracer
StackMap stack: io.vertx.core.eventbus.impl.MessageImpl io.vertx.core.spi.tracing.VertxTracer io.vertx.core.impl.ContextInternal io.vertx.core.spi.tracing.SpanKind io.vertx.core.tracing.TracingPolicy io.vertx.core.eventbus.impl.MessageImpl java.lang.String
17: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
invokevirtual io.vertx.core.eventbus.impl.MessageImpl.headers:()Lio/vertx/core/MultiMap;
getstatic io.vertx.core.eventbus.impl.MessageTagExtractor.INSTANCE:Lio/vertx/core/eventbus/impl/MessageTagExtractor;
invokeinterface io.vertx.core.spi.tracing.VertxTracer.receiveRequest:(Lio/vertx/core/Context;Lio/vertx/core/spi/tracing/SpanKind;Lio/vertx/core/tracing/TracingPolicy;Ljava/lang/Object;Ljava/lang/String;Ljava/lang/Iterable;Lio/vertx/core/spi/tracing/TagExtractor;)Ljava/lang/Object;
putfield io.vertx.core.eventbus.impl.MessageImpl.trace:Ljava/lang/Object;
18: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/HandlerRegistration;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.context:Lio/vertx/core/impl/ContextInternal;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.handler:Lio/vertx/core/Handler;
invokevirtual io.vertx.core.eventbus.impl.HandlerRegistration.dispatch:(Lio/vertx/core/eventbus/Message;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;)V
19: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
getfield io.vertx.core.eventbus.impl.MessageImpl.trace:Ljava/lang/Object;
astore 3
start local 3 20: aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
getfield io.vertx.core.eventbus.impl.MessageImpl.replyAddress:Ljava/lang/String;
ifnonnull 24
aload 3
ifnull 24
21: aload 2
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.context:Lio/vertx/core/impl/ContextInternal;
aconst_null
aload 3
aconst_null
invokestatic io.vertx.core.spi.tracing.TagExtractor.empty:()Lio/vertx/core/spi/tracing/TagExtractor;
invokeinterface io.vertx.core.spi.tracing.VertxTracer.sendResponse:(Lio/vertx/core/Context;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Throwable;Lio/vertx/core/spi/tracing/TagExtractor;)V
end local 3 22: goto 24
23: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.this$0:Lio/vertx/core/eventbus/impl/HandlerRegistration;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.context:Lio/vertx/core/impl/ContextInternal;
aload 0
getfield io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext.handler:Lio/vertx/core/Handler;
invokevirtual io.vertx.core.eventbus.impl.HandlerRegistration.dispatch:(Lio/vertx/core/eventbus/Message;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/Handler;)V
end local 2 end local 1 24: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lio/vertx/core/eventbus/impl/HandlerRegistration$InboundDeliveryContext;
2 6 1 handler Lio/vertx/core/Handler<Lio/vertx/core/eventbus/DeliveryContext;>;
8 9 1 t Ljava/lang/Throwable;
11 24 1 m Ljava/lang/Object;
12 24 2 tracer Lio/vertx/core/spi/tracing/VertxTracer;
20 22 3 trace Ljava/lang/Object;
Exception table:
from to target type
1 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.HandlerRegistration$InboundDeliveryContext.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/HandlerRegistration$InboundDeliveryContext;
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.HandlerRegistration$InboundDeliveryContext.message:Lio/vertx/core/eventbus/impl/MessageImpl;
getfield io.vertx.core.eventbus.impl.MessageImpl.receivedBody:Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/eventbus/impl/HandlerRegistration$InboundDeliveryContext;
}
Signature: Ljava/lang/Object;Lio/vertx/core/eventbus/DeliveryContext<TT;>;
SourceFile: "HandlerRegistration.java"
NestHost: io.vertx.core.eventbus.impl.HandlerRegistration
InnerClasses:
private InboundDeliveryContext = io.vertx.core.eventbus.impl.HandlerRegistration$InboundDeliveryContext of io.vertx.core.eventbus.impl.HandlerRegistration
public abstract Entry = java.util.Map$Entry of java.util.Map