public class io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> implements io.vertx.rxjava.core.streams.WriteStream<io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.rxjava.kafka.client.producer.KafkaProducer
super_class: java.lang.Object
{
public static final io.vertx.lang.rx.TypeArg<io.vertx.rxjava.kafka.client.producer.KafkaProducer> __TYPE_ARG;
descriptor: Lio/vertx/lang/rx/TypeArg;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/lang/rx/TypeArg<Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;>;
private final io.vertx.kafka.client.producer.KafkaProducer<K, V> delegate;
descriptor: Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
public final io.vertx.lang.rx.TypeArg<K> __typeArg_0;
descriptor: Lio/vertx/lang/rx/TypeArg;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Lio/vertx/lang/rx/TypeArg<TK;>;
public final io.vertx.lang.rx.TypeArg<V> __typeArg_1;
descriptor: Lio/vertx/lang/rx/TypeArg;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Lio/vertx/lang/rx/TypeArg<TV;>;
public java.lang.String toString();
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
public boolean equals(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
o
public int hashCode();
descriptor: ()I
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
public void <init>(io.vertx.kafka.client.producer.KafkaProducer);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)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\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tsubscriber cannot be resolved to a variable\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.rx cannot be resolved\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
delegate
public void <init>(io.vertx.kafka.client.producer.KafkaProducer, io.vertx.lang.rx.TypeArg<K>, io.vertx.lang.rx.TypeArg<V>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg;Lio/vertx/lang/rx/TypeArg;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tsubscriber cannot be resolved to a variable\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.rx cannot be resolved\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx cannot be resolved to a type\n\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg<TK;>;Lio/vertx/lang/rx/TypeArg<TV;>;)V
MethodParameters:
Name Flags
delegate
typeArg_0
typeArg_1
public io.vertx.kafka.client.producer.KafkaProducer getDelegate();
descriptor: ()Lio/vertx/kafka/client/producer/KafkaProducer;
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
public void end();
descriptor: ()V
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public rx.Single<java.lang.Void> rxEnd();
descriptor: ()Lrx/Single;
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\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: ()Lrx/Single<Ljava/lang/Void;>;
public void end(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;)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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)V
MethodParameters:
Name Flags
data
public void end(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
data
handler
public rx.Single<java.lang.Void> rxEnd(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;)Lrx/Single;
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\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lrx/Single<Ljava/lang/Void;>;
MethodParameters:
Name Flags
data
public static <K, V> io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.rxjava.core.Vertx, java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/rxjava/core/Vertx;Ljava/lang/String;Ljava/util/Map;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/rxjava/core/Vertx;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
public static <K, V> io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.rxjava.core.Vertx, java.lang.String, java.util.Map<java.lang.String, java.lang.String>, java.lang.Class<K>, java.lang.Class<V>);
descriptor: (Lio/vertx/rxjava/core/Vertx;Ljava/lang/String;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=5, args_size=5
0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/rxjava/core/Vertx;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
keyType
valueType
public static <K, V> io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> create(io.vertx.rxjava.core.Vertx, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/rxjava/core/Vertx;Ljava/util/Map;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/rxjava/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
config
public static <K, V> io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> create(io.vertx.rxjava.core.Vertx, java.util.Map<java.lang.String, java.lang.String>, java.lang.Class<K>, java.lang.Class<V>);
descriptor: (Lio/vertx/rxjava/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=4
0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tio.vertx.lang.rxjava cannot be resolved\n\tio.vertx.lang.rxjava cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/rxjava/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
config
keyType
valueType
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> write(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
kafkaProducerRecord
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> setWriteQueueMaxSize(int);
descriptor: (I)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (I)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
i
public boolean writeQueueFull();
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> drainHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> write(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
data
handler
public rx.Single<java.lang.Void> rxWrite(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;)Lrx/Single;
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\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lrx/Single<Ljava/lang/Void;>;
MethodParameters:
Name Flags
data
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> send(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
record
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> send(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.producer.RecordMetadata>>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/producer/RecordMetadata;>;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
record
handler
public rx.Single<io.vertx.kafka.client.producer.RecordMetadata> rxSend(io.vertx.rxjava.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord;)Lrx/Single;
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\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lrx/Single<Lio/vertx/kafka/client/producer/RecordMetadata;>;
MethodParameters:
Name Flags
record
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> partitionsFor(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.kafka.client.common.PartitionInfo>>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
topic
handler
public rx.Single<java.util.List<io.vertx.kafka.client.common.PartitionInfo>> rxPartitionsFor(java.lang.String);
descriptor: (Ljava/lang/String;)Lrx/Single;
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\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Ljava/lang/String;)Lrx/Single<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;
MethodParameters:
Name Flags
topic
public io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> flush(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
completionHandler
public void close();
descriptor: ()V
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
public rx.Single<java.lang.Void> rxClose();
descriptor: ()Lrx/Single;
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\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: ()Lrx/Single<Ljava/lang/Void;>;
public void close(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (JLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
timeout
completionHandler
public rx.Single<java.lang.Void> rxClose(long);
descriptor: (J)Lrx/Single;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.rx 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/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (J)Lrx/Single<Ljava/lang/Void;>;
MethodParameters:
Name Flags
timeout
public static <K, V> io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> newInstance(io.vertx.kafka.client.producer.KafkaProducer);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/kafka/client/producer/KafkaProducer;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
arg
public static <K, V> io.vertx.rxjava.kafka.client.producer.KafkaProducer<K, V> newInstance(io.vertx.kafka.client.producer.KafkaProducer, io.vertx.lang.rx.TypeArg<K>, io.vertx.lang.rx.TypeArg<V>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg;Lio/vertx/lang/rx/TypeArg;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg<TK;>;Lio/vertx/lang/rx/TypeArg<TV;>;)Lio/vertx/rxjava/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
arg
__typeArg_K
__typeArg_V
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/rxjava/core/streams/WriteStream<Lio/vertx/rxjava/kafka/client/producer/KafkaProducerRecord<TK;TV;>;>;
SourceFile: "KafkaProducer.java"
RuntimeVisibleAnnotations:
io.vertx.lang.rx.RxGen(value = Lio/vertx/kafka/client/producer/KafkaProducer;)
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-rx/vertx-rx-java: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)