Dependencies
Declarations
-
examples
-
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
-
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
-
MqttServerOptions
-
MqttTopicSubscription
-
MqttWill
-
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
-
MqttServerImpl
-
MqttTopicSubscriptionImpl
-
messages
Java files
Class files