| Modifier and Type | Method and Description |
|---|---|
static ServerMessage |
MQTTUtil.createPubRelMessage(MQTTSession session,
org.apache.activemq.artemis.api.core.SimpleString address,
int messageId) |
static ServerMessage |
MQTTUtil.createServerMessageFromByteBuf(MQTTSession session,
String topic,
boolean retain,
int qos,
io.netty.buffer.ByteBuf payload) |
static ServerMessage |
MQTTUtil.createServerMessageFromString(MQTTSession session,
String payload,
String topic,
int qos,
boolean retain) |
| Constructor and Description |
|---|
MQTTConnectionManager(MQTTSession session) |
MQTTPublishManager(MQTTSession session) |
MQTTRetainMessageManager(MQTTSession session) |
MQTTSessionCallback(MQTTSession session,
MQTTConnection connection) |
MQTTSubscriptionManager(MQTTSession session) |
Copyright © 2023 The Apache Software Foundation. All Rights Reserved.