Uses of Class
io.vertx.mutiny.mqtt.MqttEndpoint

Packages that use MqttEndpoint

Package	Description
io.vertx.mutiny.mqtt

Uses of MqttEndpoint in io.vertx.mutiny.mqtt

Fields in io.vertx.mutiny.mqtt with type parameters of type MqttEndpoint

Modifier and Type	Field	Description
static final TypeArg<MqttEndpoint>	MqttEndpoint.__TYPE_ARG

Methods in io.vertx.mutiny.mqtt that return MqttEndpoint

Modifier and Type	Method	Description
MqttEndpoint	MqttEndpoint.accept()
MqttEndpoint	MqttEndpoint.accept(boolean sessionPresent)
MqttEndpoint	MqttEndpoint.accept(boolean sessionPresent, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.autoKeepAlive(boolean isAutoKeepAlive)
MqttEndpoint	MqttEndpoint.closeHandler(Runnable handler)
MqttEndpoint	MqttEndpoint.disconnect(io.vertx.mqtt.messages.codes.MqttDisconnectReasonCode code, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.disconnectHandler(Runnable handler)
MqttEndpoint	MqttEndpoint.disconnectMessageHandler(Consumer<MqttDisconnectMessage> handler)
MqttEndpoint	MqttEndpoint.exceptionHandler(Consumer<Throwable> handler)
static MqttEndpoint	MqttEndpoint.newInstance(io.vertx.mqtt.MqttEndpoint arg)
MqttEndpoint	MqttEndpoint.pingHandler(Runnable handler)
MqttEndpoint	MqttEndpoint.pong()
MqttEndpoint	MqttEndpoint.publishAcknowledge(int publishMessageId)
MqttEndpoint	MqttEndpoint.publishAcknowledge(int publishMessageId, io.vertx.mqtt.messages.codes.MqttPubAckReasonCode reasonCode, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.publishAcknowledgeHandler(Consumer<Integer> handler)
MqttEndpoint	MqttEndpoint.publishAcknowledgeMessageHandler(Consumer<MqttPubAckMessage> handler)
MqttEndpoint	MqttEndpoint.publishAndForget(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain)	Variant of publish(String,io.vertx.mutiny.core.buffer.Buffer,MqttQoS,boolean,boolean) that ignores the result of the operation.
MqttEndpoint	MqttEndpoint.publishAndForget(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId)	Variant of publish(String,io.vertx.mutiny.core.buffer.Buffer,MqttQoS,boolean,boolean,int) that ignores the result of the operation.
MqttEndpoint	MqttEndpoint.publishAndForget(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, io.netty.handler.codec.mqtt.MqttProperties properties)	Variant of publish(String,io.vertx.mutiny.core.buffer.Buffer,MqttQoS,boolean,boolean,int,MqttProperties) that ignores the result of the operation.
MqttEndpoint	MqttEndpoint.publishAutoAck(boolean isPublishAutoAck)
MqttEndpoint	MqttEndpoint.publishComplete(int publishMessageId)
MqttEndpoint	MqttEndpoint.publishComplete(int publishMessageId, io.vertx.mqtt.messages.codes.MqttPubCompReasonCode reasonCode, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.publishCompletionHandler(Consumer<Integer> handler)
MqttEndpoint	MqttEndpoint.publishCompletionMessageHandler(Consumer<MqttPubCompMessage> handler)
MqttEndpoint	MqttEndpoint.publishHandler(Consumer<MqttPublishMessage> handler)
MqttEndpoint	MqttEndpoint.publishReceived(int publishMessageId)
MqttEndpoint	MqttEndpoint.publishReceived(int publishMessageId, io.vertx.mqtt.messages.codes.MqttPubRecReasonCode reasonCode, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.publishReceivedHandler(Consumer<Integer> handler)
MqttEndpoint	MqttEndpoint.publishReceivedMessageHandler(Consumer<MqttPubRecMessage> handler)
MqttEndpoint	MqttEndpoint.publishRelease(int publishMessageId)
MqttEndpoint	MqttEndpoint.publishRelease(int publishMessageId, io.vertx.mqtt.messages.codes.MqttPubRelReasonCode reasonCode, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.publishReleaseHandler(Consumer<Integer> handler)
MqttEndpoint	MqttEndpoint.publishReleaseMessageHandler(Consumer<MqttPubRelMessage> handler)
MqttEndpoint	MqttEndpoint.reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode)
MqttEndpoint	MqttEndpoint.reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.setClientIdentifier(String clientIdentifier)
MqttEndpoint	MqttEndpoint.subscribeAcknowledge(int subscribeMessageId, List<io.netty.handler.codec.mqtt.MqttQoS> grantedQoSLevels)
MqttEndpoint	MqttEndpoint.subscribeAcknowledge(int subscribeMessageId, List<io.vertx.mqtt.messages.codes.MqttSubAckReasonCode> reasonCodes, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.subscribeHandler(Consumer<MqttSubscribeMessage> handler)
MqttEndpoint	MqttEndpoint.unsubscribeAcknowledge(int unsubscribeMessageId)
MqttEndpoint	MqttEndpoint.unsubscribeAcknowledge(int unsubscribeMessageId, List<io.vertx.mqtt.messages.codes.MqttUnsubAckReasonCode> reasonCodes, io.netty.handler.codec.mqtt.MqttProperties properties)
MqttEndpoint	MqttEndpoint.unsubscribeHandler(Consumer<MqttUnsubscribeMessage> handler)

Method parameters in io.vertx.mutiny.mqtt with type arguments of type MqttEndpoint

Modifier and Type	Method	Description
MqttServer	MqttServer.endpointHandler(Consumer<MqttEndpoint> handler)