public class io.vertx.proton.streams.impl.ProtonPublisherWrapperImpl implements io.vertx.proton.streams.ProtonPublisher<org.apache.qpid.proton.message.Message>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.proton.streams.impl.ProtonPublisherWrapperImpl
super_class: java.lang.Object
{
private io.vertx.proton.streams.impl.ProtonPublisherImpl delegate;
descriptor: Lio/vertx/proton/streams/impl/ProtonPublisherImpl;
flags: (0x0002) ACC_PRIVATE
public void <init>(io.vertx.proton.streams.impl.ProtonPublisherImpl);
descriptor: (Lio/vertx/proton/streams/impl/ProtonPublisherImpl;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tThe import org.reactivestreams cannot be resolved\n\tThe import org.reactivestreams cannot be resolved\n\tThe hierarchy of the type ProtonPublisherWrapperImpl is inconsistent\n\tSubscriber cannot be resolved to a type\n\tThe method subscribe(Subscriber<? super Delivery>) from the type ProtonPublisherImpl refers to the missing type Subscriber\n\tSubscriber cannot be resolved to a type\n\tSubscriber cannot be resolved to a type\n\tSubscriber cannot be resolved to a type\n\tSubscriber cannot be resolved to a type\n\tSubscription cannot be resolved to a type\n\tSubscriber cannot be resolved to a type\n\tThe method onNext(Delivery) of type ProtonPublisherWrapperImpl.AmqpSubscriberWrapperImpl must override or implement a supertype method\n\tSubscriber cannot be resolved to a type\n\tThe method onError(Throwable) of type ProtonPublisherWrapperImpl.AmqpSubscriberWrapperImpl must override or implement a supertype method\n\tSubscriber cannot be resolved to a type\n\tThe method onComplete() of type ProtonPublisherWrapperImpl.AmqpSubscriberWrapperImpl must override or implement a supertype method\n\tSubscriber cannot be resolved to a type\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
MethodParameters:
Name Flags
delegate
public void subscribe(Subscriber<? super org.apache.qpid.proton.message.Message>);
descriptor: (LSubscriber;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tSubscriber cannot be resolved to a type\n\tThe method subscribe(Subscriber<? super Delivery>) from the type ProtonPublisherImpl refers to the missing type Subscriber\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
Signature: (LSubscriber<-Lorg/apache/qpid/proton/message/Message;>;)V
MethodParameters:
Name Flags
subscriber
public boolean isEmitOnConnectionEnd();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
public void setEmitOnConnectionEnd(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
MethodParameters:
Name Flags
emitOnConnectionEnd
public io.vertx.proton.ProtonReceiver getLink();
descriptor: ()Lio/vertx/proton/ProtonReceiver;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
public java.lang.String getRemoteAddress();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
public io.vertx.proton.streams.ProtonPublisher<org.apache.qpid.proton.message.Message> setSource(org.apache.qpid.proton.amqp.transport.Source);
descriptor: (Lorg/apache/qpid/proton/amqp/transport/Source;)Lio/vertx/proton/streams/ProtonPublisher;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
Signature: (Lorg/apache/qpid/proton/amqp/transport/Source;)Lio/vertx/proton/streams/ProtonPublisher<Lorg/apache/qpid/proton/message/Message;>;
MethodParameters:
Name Flags
source
public org.apache.qpid.proton.amqp.transport.Source getSource();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Source;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
public io.vertx.proton.streams.ProtonPublisher<org.apache.qpid.proton.message.Message> setTarget(org.apache.qpid.proton.amqp.transport.Target);
descriptor: (Lorg/apache/qpid/proton/amqp/transport/Target;)Lio/vertx/proton/streams/ProtonPublisher;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
Signature: (Lorg/apache/qpid/proton/amqp/transport/Target;)Lio/vertx/proton/streams/ProtonPublisher<Lorg/apache/qpid/proton/message/Message;>;
MethodParameters:
Name Flags
target
public org.apache.qpid.proton.amqp.transport.Target getTarget();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Target;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
public org.apache.qpid.proton.amqp.transport.Source getRemoteSource();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Source;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
public org.apache.qpid.proton.amqp.transport.Target getRemoteTarget();
descriptor: ()Lorg/apache/qpid/proton/amqp/transport/Target;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/proton/streams/impl/ProtonPublisherWrapperImpl;
}
Signature: Ljava/lang/Object;Lio/vertx/proton/streams/ProtonPublisher<Lorg/apache/qpid/proton/message/Message;>;
SourceFile: "ProtonPublisherWrapperImpl.java"
NestMembers:
io.vertx.proton.streams.impl.ProtonPublisherWrapperImpl$AmqpSubscriberWrapperImpl
InnerClasses:
private AmqpSubscriberWrapperImpl = io.vertx.proton.streams.impl.ProtonPublisherWrapperImpl$AmqpSubscriberWrapperImpl of io.vertx.proton.streams.impl.ProtonPublisherWrapperImpl