public interface io.vertx.mqtt.MqttEndpoint
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: io.vertx.mqtt.MqttEndpoint
super_class: java.lang.Object
{
public abstract void close();
descriptor: ()V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract io.vertx.core.net.SocketAddress remoteAddress();
descriptor: ()Lio/vertx/core/net/SocketAddress;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract io.vertx.core.net.SocketAddress localAddress();
descriptor: ()Lio/vertx/core/net/SocketAddress;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract boolean isSsl();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract javax.net.ssl.SSLSession sslSession();
descriptor: ()Ljavax/net/ssl/SSLSession;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.GenIgnore()
RuntimeVisibleTypeAnnotations:
METHOD_RETURN
io.vertx.codegen.annotations.GenIgnore()
public abstract java.lang.String clientIdentifier();
descriptor: ()Ljava/lang/String;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract io.vertx.mqtt.MqttAuth auth();
descriptor: ()Lio/vertx/mqtt/MqttAuth;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract io.vertx.mqtt.MqttWill will();
descriptor: ()Lio/vertx/mqtt/MqttWill;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract int protocolVersion();
descriptor: ()I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract java.lang.String protocolName();
descriptor: ()Ljava/lang/String;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract boolean isCleanSession();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract int keepAliveTimeSeconds();
descriptor: ()I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract int lastMessageId();
descriptor: ()I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.CacheReturn()
public abstract void subscriptionAutoAck(boolean);
descriptor: (Z)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
isSubscriptionAutoAck
public abstract boolean isSubscriptionAutoAck();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract io.vertx.mqtt.MqttEndpoint publishAutoAck(boolean);
descriptor: (Z)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
isPublishAutoAck
public abstract boolean isPublishAutoAck();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract io.vertx.mqtt.MqttEndpoint autoKeepAlive(boolean);
descriptor: (Z)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
isAutoKeepAlive
public abstract boolean isAutoKeepAlive();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract boolean isConnected();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract io.vertx.mqtt.MqttEndpoint setClientIdentifier(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
clientIdentifier
public abstract io.vertx.mqtt.MqttEndpoint disconnectHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint subscribeHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttSubscribeMessage>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttSubscribeMessage;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint unsubscribeHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttUnsubscribeMessage>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttUnsubscribeMessage;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint publishHandler(io.vertx.core.Handler<io.vertx.mqtt.messages.MqttPublishMessage>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Lio/vertx/mqtt/messages/MqttPublishMessage;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint publishAcknowledgeHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint publishReceivedHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint publishReleaseHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint publishCompletionHandler(io.vertx.core.Handler<java.lang.Integer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Integer;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint pingHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint closeHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.vertx.mqtt.MqttEndpoint accept();
descriptor: ()Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
public abstract io.vertx.mqtt.MqttEndpoint accept(boolean);
descriptor: (Z)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
sessionPresent
public abstract io.vertx.mqtt.MqttEndpoint reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode);
descriptor: (Lio/netty/handler/codec/mqtt/MqttConnectReturnCode;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
returnCode
public abstract io.vertx.mqtt.MqttEndpoint subscribeAcknowledge(int, java.util.List<io.netty.handler.codec.mqtt.MqttQoS>);
descriptor: (ILjava/util/List;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (ILjava/util/List<Lio/netty/handler/codec/mqtt/MqttQoS;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
subscribeMessageId
grantedQoSLevels
public abstract io.vertx.mqtt.MqttEndpoint unsubscribeAcknowledge(int);
descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
unsubscribeMessageId
public abstract io.vertx.mqtt.MqttEndpoint publishAcknowledge(int);
descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
publishMessageId
public abstract io.vertx.mqtt.MqttEndpoint publishReceived(int);
descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
publishMessageId
public abstract io.vertx.mqtt.MqttEndpoint publishRelease(int);
descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
publishMessageId
public abstract io.vertx.mqtt.MqttEndpoint publishComplete(int);
descriptor: (I)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
publishMessageId
public abstract io.vertx.mqtt.MqttEndpoint publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZ)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
topic
payload
qosLevel
isDup
isRetain
public abstract io.vertx.mqtt.MqttEndpoint publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
topic
payload
qosLevel
isDup
isRetain
publishSentHandler
public abstract io.vertx.mqtt.MqttEndpoint publish(java.lang.String, io.vertx.core.buffer.Buffer, io.netty.handler.codec.mqtt.MqttQoS, boolean, boolean, int, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
descriptor: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZILio/vertx/core/Handler;)Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Ljava/lang/String;Lio/vertx/core/buffer/Buffer;Lio/netty/handler/codec/mqtt/MqttQoS;ZZILio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)Lio/vertx/mqtt/MqttEndpoint;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
topic
payload
qosLevel
isDup
isRetain
messageId
publishSentHandler
public abstract io.vertx.mqtt.MqttEndpoint pong();
descriptor: ()Lio/vertx/mqtt/MqttEndpoint;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
}
SourceFile: "MqttEndpoint.java"
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.VertxGen()