diff --git a/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClient.java b/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClient.java index 143862d32..b30078286 100644 --- a/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClient.java +++ b/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClient.java @@ -11,12 +11,19 @@ import software.amazon.awssdk.crt.io.TlsContext; /** + *

Deprecated. We strongly recommend using {@link software.amazon.awssdk.crt.mqtt5.Mqtt5Client}.

+ * + *

There are no current plans to fully deprecate the MQTT 3.1.1 client but it is highly recommended + * customers migrate to the MQTT5 client to access a more robust feature set, clearer error handling, + * and lifetime management. More details can be found in the GitHub Repo FAQ

+ * * This class wraps aws-c-mqtt to provide the basic MQTT pub/sub functionalities * via the AWS Common Runtime * * One MqttClient class is needed per application. It can create any number of connections to * any number of MQTT endpoints */ +@Deprecated public class MqttClient extends CrtResource { private TlsContext tlsContext; diff --git a/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClientConnection.java b/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClientConnection.java index c4ac6af1f..214adb34b 100644 --- a/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClientConnection.java +++ b/src/main/java/software/amazon/awssdk/crt/mqtt/MqttClientConnection.java @@ -22,12 +22,19 @@ import java.util.function.Consumer; /** + *

Deprecated. We strongly recommend using {@link software.amazon.awssdk.crt.mqtt5.Mqtt5Client}.

+ * + *

There are no current plans to fully deprecate the MQTT 3.1.1 client but it is highly recommended + * customers migrate to the MQTT5 client to access a more robust feature set, clearer error handling, + * and lifetime management. More details can be found in the GitHub Repo FAQ

+ * * This class wraps aws-c-mqtt to provide the basic MQTT pub/sub functionality * via the AWS Common Runtime * * MqttClientConnection represents a single connection from one MqttClient to an * MQTT service endpoint */ +@Deprecated public class MqttClientConnection extends CrtResource { private static final int MAX_PORT = 65535;