Dependencies
- avalon-framework/avalon-framework/4.1.5 (available as org.apache.avalon.framework/avalon-framework-impl/4.3.1)
- com.fasterxml.jackson.core/jackson-annotations/2.9.0
- com.fasterxml.jackson.core/jackson-core/2.9.9
- com.fasterxml.jackson.core/jackson-databind/2.9.9.1
- com.github.jponge/lzma-java/1.3
- com.google.protobuf.nano/protobuf-javanano/3.0.0-alpha-5
- com.google.protobuf/protobuf-java/2.6.1
- com.jcraft/jzlib/1.1.3
- commons-logging/commons-logging/1.2
- com.ning/compress-lzf/1.0.3
- com.sun/tools/1.8
- io.netty/netty-buffer/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http2/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-http/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-mqtt/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-codec-socks/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-handler-proxy/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-resolver-dns/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-epoll/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-kqueue/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.netty/netty-transport-native-unix-common/4.1.34.Final (available as io.netty/netty-all/4.1.25.Final)
- io.vertx/vertx-codegen/3.8.0
- io.vertx/vertx-core/3.8.0
- io.vertx/vertx-docgen/0.9.2
- java/11
- log4j/log4j/1.2.17
- logkit/logkit/1.0.1
- net.jpountz.lz4/lz4/1.3.0
- org.apache.geronimo.specs/geronimo-jms_1.1_spec/1.0
- org.apache.logging.log4j/log4j-api/2.6.2
- org.bouncycastle/bcpkix-jdk15on/1.54
- org.bouncycastle/bcprov-jdk15on/1.54
- org.conscrypt/conscrypt-openjdk-uber/1.3.0
- org.jboss.marshalling/jboss-marshalling/1.4.11.Final
- org.mvel/mvel2/2.3.1.Final
- org.slf4j/slf4j-api/1.7.21
Declarations
-
examples
-
VertxMqttClientExamples
-
VertxMqttServerExamples
-
-
io
-
vertx
-
mqtt
-
MqttAuth
-
MqttClient
-
create(Vertx, MqttClientOptions): MqttClient
-
create(Vertx): MqttClient
-
connect(int, String, Handler<AsyncResult<MqttConnAckMessage>>): MqttClient
-
connect(int, String, String, Handler<AsyncResult<MqttConnAckMessage>>): MqttClient
-
disconnect(): MqttClient
-
disconnect(Handler<AsyncResult<Void>>): MqttClient
-
publish(String, Buffer, MqttQoS, boolean, boolean): MqttClient
-
publish(String, Buffer, MqttQoS, boolean, boolean, Handler<AsyncResult<Integer>>): MqttClient
-
publishCompletionHandler(Handler<Integer>): MqttClient
-
publishHandler(Handler<MqttPublishMessage>): MqttClient
-
subscribeCompletionHandler(Handler<MqttSubAckMessage>): MqttClient
-
subscribe(String, int): MqttClient
-
subscribe(String, int, Handler<AsyncResult<Integer>>): MqttClient
-
subscribe(Map<String, Integer>): MqttClient
-
subscribe(Map<String, Integer>, Handler<AsyncResult<Integer>>): MqttClient
-
unsubscribeCompletionHandler(Handler<Integer>): MqttClient
-
unsubscribe(String): MqttClient
-
unsubscribe(String, Handler<AsyncResult<Integer>>): MqttClient
-
pingResponseHandler(Handler<Void>): MqttClient
-
exceptionHandler(Handler<Throwable>): MqttClient
-
closeHandler(Handler<Void>): MqttClient
-
ping(): MqttClient
-
clientId(): String
-
isConnected(): boolean
-
-
MqttClientOptions
-
DEFAULT_WILL_RETAIN: boolean
-
DEFAULT_PORT: int
-
DEFAULT_TSL_PORT: int
-
DEFAULT_HOST: String
-
DEFAULT_WILL_QOS: int
-
DEFAULT_KEEP_ALIVE_TIME_SECONDS: int
-
DEFAULT_MAX_INFLIGHT_QUEUE: int
-
DEFAULT_CLEAN_SESSION: boolean
-
DEFAULT_WILL_FLAG: boolean
-
DEFAULT_MAX_MESSAGE_SIZE: int
-
clientId: String
-
username: String
-
password: String
-
willTopic: String
-
willMessage: String
-
cleanSession: boolean
-
willFlag: boolean
-
willQoS: int
-
willRetain: boolean
-
keepAliveTimeSeconds: int
-
isAutoKeepAlive: boolean
-
isAutoGeneratedClientId: boolean
-
maxInflightQueue: int
-
maxMessageSize: int
-
MqttClientOptions(): void
-
MqttClientOptions(JsonObject): void
-
MqttClientOptions(MqttClientOptions): void
-
hasUsername(): boolean
-
hasPassword(): boolean
-
isCleanSession(): boolean
-
isWillFlag(): boolean
-
isWillRetain(): boolean
-
getWillQoS(): int
-
getKeepAliveTimeSeconds(): int
-
getUsername(): String
-
getPassword(): String
-
getClientId(): String
-
getWillTopic(): String
-
getWillMessage(): String
-
setClientId(String): MqttClientOptions
-
setUsername(String): MqttClientOptions
-
setPassword(String): MqttClientOptions
-
setWillTopic(String): MqttClientOptions
-
setWillMessage(String): MqttClientOptions
-
setCleanSession(boolean): MqttClientOptions
-
setWillFlag(boolean): MqttClientOptions
-
setWillQoS(int): MqttClientOptions
-
setWillRetain(boolean): MqttClientOptions
-
setKeepAliveTimeSeconds(int): MqttClientOptions
-
getMaxInflightQueue(): int
-
setMaxInflightQueue(int): MqttClientOptions
-
setAutoKeepAlive(boolean): MqttClientOptions
-
setAutoGeneratedClientId(boolean): MqttClientOptions
-
isAutoKeepAlive(): boolean
-
isAutoGeneratedClientId(): boolean
-
getMaxMessageSize(): int
-
setReceiveBufferSize(int): MqttClientOptions
-
setMaxMessageSize(int): MqttClientOptions
-
setIdleTimeout(int): MqttClientOptions
-
setSsl(boolean): MqttClientOptions
-
setTrustStoreOptions(JksOptions): MqttClientOptions
-
setTrustAll(boolean): MqttClientOptions
-
setKeyCertOptions(KeyCertOptions): MqttClientOptions
-
setKeyStoreOptions(JksOptions): MqttClientOptions
-
setPfxKeyCertOptions(PfxOptions): MqttClientOptions
-
setPemKeyCertOptions(PemKeyCertOptions): MqttClientOptions
-
setTrustOptions(TrustOptions): MqttClientOptions
-
setPemTrustOptions(PemTrustOptions): MqttClientOptions
-
setPfxTrustOptions(PfxOptions): MqttClientOptions
-
addEnabledCipherSuite(String): MqttClientOptions
-
addEnabledSecureTransportProtocol(String): MqttClientOptions
-
addCrlPath(String): MqttClientOptions
-
addCrlValue(Buffer): MqttClientOptions
-
toString(): String
-
-
MqttClientOptionsConverter
-
MqttConnectionException
-
MqttEndpoint
-
close(): void
-
remoteAddress(): SocketAddress
-
clientIdentifier(): String
-
auth(): MqttAuth
-
localAddress(): SocketAddress
-
isSsl(): boolean
-
sslSession(): SSLSession
-
will(): MqttWill
-
protocolVersion(): int
-
protocolName(): String
-
isCleanSession(): boolean
-
keepAliveTimeSeconds(): int
-
lastMessageId(): int
-
subscriptionAutoAck(boolean): void
-
isSubscriptionAutoAck(): boolean
-
publishAutoAck(boolean): MqttEndpoint
-
isPublishAutoAck(): boolean
-
autoKeepAlive(boolean): MqttEndpoint
-
isAutoKeepAlive(): boolean
-
isConnected(): boolean
-
setClientIdentifier(String): MqttEndpoint
-
disconnectHandler(Handler<Void>): MqttEndpoint
-
subscribeHandler(Handler<MqttSubscribeMessage>): MqttEndpoint
-
unsubscribeHandler(Handler<MqttUnsubscribeMessage>): MqttEndpoint
-
publishHandler(Handler<MqttPublishMessage>): MqttEndpoint
-
publishAcknowledgeHandler(Handler<Integer>): MqttEndpoint
-
publishReceivedHandler(Handler<Integer>): MqttEndpoint
-
publishReleaseHandler(Handler<Integer>): MqttEndpoint
-
publishCompletionHandler(Handler<Integer>): MqttEndpoint
-
pingHandler(Handler<Void>): MqttEndpoint
-
closeHandler(Handler<Void>): MqttEndpoint
-
exceptionHandler(Handler<Throwable>): MqttEndpoint
-
accept(): MqttEndpoint
-
accept(boolean): MqttEndpoint
-
reject(MqttConnectReturnCode): MqttEndpoint
-
subscribeAcknowledge(int, List<MqttQoS>): MqttEndpoint
-
unsubscribeAcknowledge(int): MqttEndpoint
-
publishAcknowledge(int): MqttEndpoint
-
publishReceived(int): MqttEndpoint
-
publishRelease(int): MqttEndpoint
-
publishComplete(int): MqttEndpoint
-
publish(String, Buffer, MqttQoS, boolean, boolean): MqttEndpoint
-
publish(String, Buffer, MqttQoS, boolean, boolean, Handler<AsyncResult<Integer>>): MqttEndpoint
-
publish(String, Buffer, MqttQoS, boolean, boolean, int, Handler<AsyncResult<Integer>>): MqttEndpoint
-
pong(): MqttEndpoint
-
-
MqttException
-
MqttServer
-
create(Vertx, MqttServerOptions): MqttServer
-
create(Vertx): MqttServer
-
listen(): MqttServer
-
listen(int, String): MqttServer
-
listen(int, String, Handler<AsyncResult<MqttServer>>): MqttServer
-
listen(int): MqttServer
-
listen(int, Handler<AsyncResult<MqttServer>>): MqttServer
-
listen(Handler<AsyncResult<MqttServer>>): MqttServer
-
endpointHandler(Handler<MqttEndpoint>): MqttServer
-
exceptionHandler(Handler<Throwable>): MqttServer
-
actualPort(): int
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
-
MqttServerOptions
-
isAutoClientId: boolean
-
DEFAULT_PORT: int
-
DEFAULT_TLS_PORT: int
-
DEFAULT_MAX_MESSAGE_SIZE: int
-
DEFAULT_TIMEOUT_ON_CONNECT: int
-
maxMessageSize: int
-
timeoutOnConnect: int
-
MqttServerOptions(): void
-
MqttServerOptions(JsonObject): void
-
MqttServerOptions(MqttServerOptions): void
-
setPort(int): MqttServerOptions
-
setHost(String): MqttServerOptions
-
setClientAuth(ClientAuth): MqttServerOptions
-
setSsl(boolean): MqttServerOptions
-
setKeyCertOptions(KeyCertOptions): MqttServerOptions
-
setKeyStoreOptions(JksOptions): MqttServerOptions
-
setPfxKeyCertOptions(PfxOptions): MqttServerOptions
-
setPemKeyCertOptions(PemKeyCertOptions): MqttServerOptions
-
setTrustOptions(TrustOptions): MqttServerOptions
-
setTrustStoreOptions(JksOptions): MqttServerOptions
-
setPemTrustOptions(PemTrustOptions): MqttServerOptions
-
setPfxTrustOptions(PfxOptions): MqttServerOptions
-
addEnabledCipherSuite(String): MqttServerOptions
-
addEnabledSecureTransportProtocol(String): MqttServerOptions
-
addCrlPath(String): MqttServerOptions
-
addCrlValue(Buffer): MqttServerOptions
-
setReceiveBufferSize(int): MqttServerOptions
-
setSni(boolean): MqttServerOptions
-
setMaxMessageSize(int): MqttServerOptions
-
getMaxMessageSize(): int
-
setAutoClientId(boolean): MqttServerOptions
-
isAutoClientId(): boolean
-
setTimeoutOnConnect(int): MqttServerOptions
-
timeoutOnConnect(): int
-
-
MqttTopicSubscription
-
MqttWill
-
isWillFlag: boolean
-
willTopic: String
-
willMessage: byte[]
-
willQos: int
-
isWillRetain: boolean
-
isWillFlag(): boolean
-
MqttWill(boolean, String, byte[], int, boolean): void
-
MqttWill(JsonObject): void
-
getWillTopic(): String
-
getWillMessage(): String
-
getWillMessageBytes(): byte[]
-
getWillQos(): int
-
isWillRetain(): boolean
-
willTopic(): String
-
willMessage(): String
-
willQos(): int
-
toJson(): JsonObject
-
-
impl
-
MqttClientImpl
-
validTopicNamePattern: Pattern
-
validTopicFilterPattern: Pattern
-
log: Logger
-
MAX_MESSAGE_ID: int
-
MAX_TOPIC_LEN: int
-
MIN_TOPIC_LEN: int
-
PROTOCOL_NAME: String
-
PROTOCOL_VERSION: int
-
DEFAULT_IDLE_TIMEOUT: int
-
options: MqttClientOptions
-
client: NetClient
-
connection: NetSocketInternal
-
ctx: Context
-
publishCompletionHandler: Handler<Integer>
-
unsubscribeCompletionHandler: Handler<Integer>
-
publishHandler: Handler<MqttPublishMessage>
-
subscribeCompletionHandler: Handler<MqttSubAckMessage>
-
connectHandler: Handler<AsyncResult<MqttConnAckMessage>>
-
pingrespHandler: Handler<Void>
-
exceptionHandler: Handler<Throwable>
-
closeHandler: Handler<Void>
-
qos1outbound: HashMap<Integer, MqttMessage>
-
qos2outbound: HashMap<Integer, MqttMessage>
-
qos2inbound: HashMap<Integer, MqttMessage>
-
messageIdCounter: int
-
countInflightQueue: int
-
isConnected: boolean
-
MqttClientImpl(Vertx, MqttClientOptions): void
-
connect(int, String, Handler<AsyncResult<MqttConnAckMessage>>): MqttClient
-
connect(int, String, String, Handler<AsyncResult<MqttConnAckMessage>>): MqttClient
-
unsubscribeCompletionHandler(): Handler<Integer>
-
doConnect(int, String, String, Handler<AsyncResult<MqttConnAckMessage>>): void
-
disconnect(): MqttClient
-
disconnect(Handler<AsyncResult<Void>>): MqttClient
-
publish(String, Buffer, MqttQoS, boolean, boolean): MqttClient
-
publish(String, Buffer, MqttQoS, boolean, boolean, Handler<AsyncResult<Integer>>): MqttClient
-
publishCompletionHandler(Handler<Integer>): MqttClient
-
publishCompletionHandler(): Handler<Integer>
-
publishHandler(Handler<MqttPublishMessage>): MqttClient
-
publishHandler(): Handler<MqttPublishMessage>
-
subscribeCompletionHandler(Handler<MqttSubAckMessage>): MqttClient
-
subscribeCompletionHandler(): Handler<MqttSubAckMessage>
-
subscribe(String, int): MqttClient
-
subscribe(String, int, Handler<AsyncResult<Integer>>): MqttClient
-
subscribe(Map<String, Integer>): MqttClient
-
subscribe(Map<String, Integer>, Handler<AsyncResult<Integer>>): MqttClient
-
unsubscribeCompletionHandler(Handler<Integer>): MqttClient
-
unsubscribe(String, Handler<AsyncResult<Integer>>): MqttClient
-
connectHandler(): Handler<AsyncResult<MqttConnAckMessage>>
-
unsubscribe(String): MqttClient
-
pingResponseHandler(Handler<Void>): MqttClient
-
pingResponseHandler(): Handler<Void>
-
exceptionHandler(Handler<Throwable>): MqttClient
-
exceptionHandler(): Handler<Throwable>
-
closeHandler(Handler<Void>): MqttClient
-
closeHandler(): Handler<Void>
-
ping(): MqttClient
-
clientId(): String
-
isConnected(): boolean
-
publishAcknowledge(int): void
-
publishReceived(MqttPublishMessage): void
-
publishComplete(int): void
-
publishRelease(int): void
-
initChannel(ChannelPipeline): void
-
nextMessageId(): int
-
connection(): NetSocketInternal
-
write(MqttMessage): void
-
handleClosed(): void
-
handleMessage(ChannelHandlerContext, Object): void
-
handlePingresp(): void
-
handleUnsuback(int): void
-
handlePuback(int): void
-
handlePubcomp(int): void
-
handlePubrec(int): void
-
handleSuback(MqttSubAckMessage): void
-
handlePublish(MqttPublishMessage): void
-
handlePubrel(int): void
-
handleConnack(MqttConnAckMessage): void
-
handleException(Throwable): void
-
generateRandomClientId(): String
-
isValidTopicName(String): boolean
-
isValidTopicFilter(String): boolean
-
isValidStringSizeInUTF8(String): boolean
-
-
MqttEndpointImpl
-
MAX_MESSAGE_ID: int
-
log: Logger
-
conn: NetSocketInternal
-
clientIdentifier: String
-
auth: MqttAuth
-
will: MqttWill
-
isCleanSession: boolean
-
protocolVersion: int
-
protocolName: String
-
keepAliveTimeoutSeconds: int
-
subscribeHandler: Handler<MqttSubscribeMessage>
-
unsubscribeHandler: Handler<MqttUnsubscribeMessage>
-
publishHandler: Handler<MqttPublishMessage>
-
pubackHandler: Handler<Integer>
-
pubrecHandler: Handler<Integer>
-
pubrelHandler: Handler<Integer>
-
pubcompHandler: Handler<Integer>
-
disconnectHandler: Handler<Void>
-
pingreqHandler: Handler<Void>
-
closeHandler: Handler<Void>
-
exceptionHandler: Handler<Throwable>
-
isConnected: boolean
-
isClosed: boolean
-
messageIdCounter: int
-
isSubscriptionAutoAck: boolean
-
isPublishAutoAck: boolean
-
isAutoKeepAlive: boolean
-
MqttEndpointImpl(NetSocketInternal, String, MqttAuth, MqttWill, boolean, int, String, int): void
-
clientIdentifier(): String
-
auth(): MqttAuth
-
will(): MqttWill
-
isCleanSession(): boolean
-
protocolVersion(): int
-
protocolName(): String
-
keepAliveTimeSeconds(): int
-
lastMessageId(): int
-
subscriptionAutoAck(boolean): void
-
isSubscriptionAutoAck(): boolean
-
publishAutoAck(boolean): MqttEndpoint
-
isPublishAutoAck(): boolean
-
autoKeepAlive(boolean): MqttEndpoint
-
isAutoKeepAlive(): boolean
-
isConnected(): boolean
-
setClientIdentifier(String): MqttEndpoint
-
disconnectHandler(Handler<Void>): MqttEndpointImpl
-
subscribeHandler(Handler<MqttSubscribeMessage>): MqttEndpointImpl
-
unsubscribeHandler(Handler<MqttUnsubscribeMessage>): MqttEndpointImpl
-
publishHandler(Handler<MqttPublishMessage>): MqttEndpointImpl
-
publishAcknowledgeHandler(Handler<Integer>): MqttEndpointImpl
-
publishReceivedHandler(Handler<Integer>): MqttEndpointImpl
-
publishReleaseHandler(Handler<Integer>): MqttEndpointImpl
-
publishCompletionHandler(Handler<Integer>): MqttEndpointImpl
-
pingHandler(Handler<Void>): MqttEndpointImpl
-
closeHandler(Handler<Void>): MqttEndpointImpl
-
exceptionHandler(Handler<Throwable>): MqttEndpointImpl
-
connack(MqttConnectReturnCode, boolean): MqttEndpointImpl
-
accept(): MqttEndpoint
-
accept(boolean): MqttEndpointImpl
-
reject(MqttConnectReturnCode): MqttEndpointImpl
-
subscribeAcknowledge(int, List<MqttQoS>): MqttEndpointImpl
-
unsubscribeAcknowledge(int): MqttEndpointImpl
-
publishAcknowledge(int): MqttEndpointImpl
-
publishReceived(int): MqttEndpointImpl
-
publishRelease(int): MqttEndpointImpl
-
publishComplete(int): MqttEndpointImpl
-
publish(String, Buffer, MqttQoS, boolean, boolean): MqttEndpointImpl
-
publish(String, Buffer, MqttQoS, boolean, boolean, Handler<AsyncResult<Integer>>): MqttEndpointImpl
-
publish(String, Buffer, MqttQoS, boolean, boolean, int, Handler<AsyncResult<Integer>>): MqttEndpointImpl
-
pong(): MqttEndpointImpl
-
handleSubscribe(MqttSubscribeMessage): void
-
handleUnsubscribe(MqttUnsubscribeMessage): void
-
handlePublish(MqttPublishMessage): void
-
handlePuback(int): void
-
handlePubrec(int): void
-
handlePubrel(int): void
-
handlePubcomp(int): void
-
handlePingreq(): void
-
handleDisconnect(): void
-
handleClosed(): void
-
handleException(Throwable): void
-
close(): void
-
localAddress(): SocketAddress
-
remoteAddress(): SocketAddress
-
isSsl(): boolean
-
sslSession(): SSLSession
-
write(MqttMessage): void
-
checkClosed(): void
-
checkConnected(): void
-
cleanup(): void
-
nextMessageId(): int
-
-
MqttServerConnection
-
log: Logger
-
endpointHandler: Handler<MqttEndpoint>
-
exceptionHandler: Handler<Throwable>
-
so: NetSocketInternal
-
endpoint: MqttEndpointImpl
-
chctx: ChannelHandlerContext
-
options: MqttServerOptions
-
init(Handler<MqttEndpoint>, Handler<Throwable>): void
-
MqttServerConnection(NetSocketInternal, MqttServerOptions): void
-
handleMessage(Object): void
-
handleConnect(MqttConnectMessage): void
-
handleSubscribe(MqttSubscribeMessage): void
-
handleUnsubscribe(MqttUnsubscribeMessage): void
-
handlePublish(MqttPublishMessage): void
-
handlePuback(int): void
-
handlePubrec(int): void
-
handlePubrel(int): void
-
handlePubcomp(int): void
-
handlePingreq(): void
-
handleDisconnect(): void
-
checkConnected(): boolean
-
-
MqttServerImpl
-
log: Logger
-
server: NetServer
-
endpointHandler: Handler<MqttEndpoint>
-
exceptionHandler: Handler<Throwable>
-
options: MqttServerOptions
-
MqttServerImpl(Vertx, MqttServerOptions): void
-
listen(): MqttServer
-
listen(int, String): MqttServer
-
listen(int): MqttServer
-
listen(int, Handler<AsyncResult<MqttServer>>): MqttServer
-
listen(Handler<AsyncResult<MqttServer>>): MqttServer
-
listen(int, String, Handler<AsyncResult<MqttServer>>): MqttServer
-
endpointHandler(Handler<MqttEndpoint>): MqttServer
-
exceptionHandler(Handler<Throwable>): MqttServer
-
actualPort(): int
-
close(): void
-
close(Handler<AsyncResult<Void>>): void
-
initChannel(ChannelPipeline): void
-
-
MqttTopicSubscriptionImpl
-
- messages
-
-
mqtt
-
vertx