diff --git a/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/MqttSubscriptionBuilder.java b/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/MqttSubscriptionBuilder.java index 4d676ad9f..34ada819e 100644 --- a/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/MqttSubscriptionBuilder.java +++ b/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/MqttSubscriptionBuilder.java @@ -36,7 +36,7 @@ public abstract class MqttSubscriptionBuilder> { private @Nullable MqttTopicFilterImpl topicFilter; - private @NotNull MqttQos maxQos = MqttSubscription.DEFAULT_QOS; + private @NotNull MqttQos maxQos = MqttSubscription.DEFAULT_MAX_QOS; private boolean noLocal = MqttSubscription.DEFAULT_NO_LOCAL; private @NotNull Mqtt5RetainHandling retainHandling = MqttSubscription.DEFAULT_RETAIN_HANDLING; private boolean retainAsPublished = MqttSubscription.DEFAULT_RETAIN_AS_PUBLISHED; diff --git a/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/mqtt3/Mqtt3SubscriptionViewBuilder.java b/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/mqtt3/Mqtt3SubscriptionViewBuilder.java index 6bcb58e64..dceff63b3 100644 --- a/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/mqtt3/Mqtt3SubscriptionViewBuilder.java +++ b/src/main/java/com/hivemq/mqtt/client2/internal/message/subscribe/mqtt3/Mqtt3SubscriptionViewBuilder.java @@ -36,7 +36,7 @@ public abstract class Mqtt3SubscriptionViewBuilder> { private @Nullable MqttTopicFilterImpl topicFilter; - private @NotNull MqttQos maxQos = Mqtt3SubscriptionView.DEFAULT_QOS; + private @NotNull MqttQos maxQos = Mqtt3SubscriptionView.DEFAULT_MAX_QOS; Mqtt3SubscriptionViewBuilder() {} diff --git a/src/main/java/com/hivemq/mqtt/client2/mqtt3/message/subscribe/Mqtt3Subscription.java b/src/main/java/com/hivemq/mqtt/client2/mqtt3/message/subscribe/Mqtt3Subscription.java index afbb5ef41..480ee9a99 100644 --- a/src/main/java/com/hivemq/mqtt/client2/mqtt3/message/subscribe/Mqtt3Subscription.java +++ b/src/main/java/com/hivemq/mqtt/client2/mqtt3/message/subscribe/Mqtt3Subscription.java @@ -35,7 +35,7 @@ public interface Mqtt3Subscription { * Default {@link MqttQos QoS} level of a Subscription. It is chosen as {@link MqttQos#EXACTLY_ONCE} as this leeds * to subscribed Publish messages being delivered with its initial {@link MqttQos QoS} level. */ - @NotNull MqttQos DEFAULT_QOS = MqttQos.EXACTLY_ONCE; + @NotNull MqttQos DEFAULT_MAX_QOS = MqttQos.EXACTLY_ONCE; /** * Creates a builder for a Subscription. diff --git a/src/main/java/com/hivemq/mqtt/client2/mqtt5/message/subscribe/Mqtt5Subscription.java b/src/main/java/com/hivemq/mqtt/client2/mqtt5/message/subscribe/Mqtt5Subscription.java index de90d68d4..025af045d 100644 --- a/src/main/java/com/hivemq/mqtt/client2/mqtt5/message/subscribe/Mqtt5Subscription.java +++ b/src/main/java/com/hivemq/mqtt/client2/mqtt5/message/subscribe/Mqtt5Subscription.java @@ -35,7 +35,7 @@ public interface Mqtt5Subscription { * Default {@link MqttQos QoS} level of a Subscription. It is chosen as {@link MqttQos#EXACTLY_ONCE} as this leeds * to subscribed Publish messages being delivered with its initial {@link MqttQos QoS} level. */ - @NotNull MqttQos DEFAULT_QOS = MqttQos.EXACTLY_ONCE; + @NotNull MqttQos DEFAULT_MAX_QOS = MqttQos.EXACTLY_ONCE; /** * The default for whether the client must not receive messages published by itself. */