Formatting

Author: SgtSilvio

Diff for: src/main/java/com/hivemq/client/internal/mqtt/codec/decoder/mqtt5/Mqtt5PublishDecoder.java

@@ -155,8 +155,7 @@ public class Mqtt5PublishDecoder implements MqttMessageDecoder {
                         throw new MqttDecoderException("malformed subscription identifier");
                     }
                     if (subscriptionIdentifier == 0) {
-                        throw new MqttDecoderException(
-                                Mqtt5DisconnectReasonCode.PROTOCOL_ERROR,
+                        throw new MqttDecoderException(Mqtt5DisconnectReasonCode.PROTOCOL_ERROR,
                                 "subscription identifier must not be 0");
                     }
                     subscriptionIdentifiersBuilder.add(subscriptionIdentifier);
@@ -174,8 +173,7 @@ public class Mqtt5PublishDecoder implements MqttMessageDecoder {
         if (topicAlias != DEFAULT_NO_TOPIC_ALIAS) {
             final MqttTopicImpl[] topicAliasMapping = context.getTopicAliasMapping();
             if ((topicAliasMapping == null) || (topicAlias > topicAliasMapping.length)) {
-                throw new MqttDecoderException(
-                        Mqtt5DisconnectReasonCode.TOPIC_ALIAS_INVALID,
+                throw new MqttDecoderException(Mqtt5DisconnectReasonCode.TOPIC_ALIAS_INVALID,
                         "topic alias must not exceed topic alias maximum");
             }
             if (topic == null) {
@@ -189,8 +187,7 @@ public class Mqtt5PublishDecoder implements MqttMessageDecoder {
                 topicAlias |= TOPIC_ALIAS_FLAG_NEW;
             }
         } else if (topic == null) {
-            throw new MqttDecoderException(
-                    Mqtt5DisconnectReasonCode.PROTOCOL_ERROR,
+            throw new MqttDecoderException(Mqtt5DisconnectReasonCode.PROTOCOL_ERROR,
                     "topic alias must be present if topic name is zero length");
         }
 

Diff for: src/main/java/com/hivemq/client/internal/mqtt/handler/auth/MqttReAuthHandler.java

@@ -158,8 +158,7 @@ void readReAuth(final @NotNull ChannelHandlerContext ctx, final @NotNull MqttAut
         }
         if (state != MqttAuthState.NONE) {
             MqttDisconnectUtil.disconnect(ctx.channel(), Mqtt5DisconnectReasonCode.PROTOCOL_ERROR,
-                    new Mqtt5AuthException(
-                            auth,
+                    new Mqtt5AuthException(auth,
                             "Must not receive AUTH with reason code REAUTHENTICATE if reauth is still pending."));
             return;
         }

Diff for: src/main/java/com/hivemq/client/internal/mqtt/handler/publish/outgoing/MqttOutgoingQosHandler.java

@@ -116,8 +116,7 @@ public void onSessionStartOrResume(
         super.onSessionStartOrResume(connectionConfig, eventLoop);
 
         final int oldSendMaximum = sendMaximum;
-        final int newSendMaximum = Math.min(
-                connectionConfig.getSendMaximum(),
+        final int newSendMaximum = Math.min(connectionConfig.getSendMaximum(),
                 UnsignedDataTypes.UNSIGNED_SHORT_MAX_VALUE - MqttSubscriptionHandler.MAX_SUB_PENDING);
         sendMaximum = newSendMaximum;
         packetIdentifiers.resize(newSendMaximum);
@@ -260,8 +259,7 @@ private void writePublish(
     private void writeQos0Publish(
             final @NotNull ChannelHandlerContext ctx, final @NotNull MqttPublishWithFlow publishWithFlow) {
 
-        ctx.write(
-                publishWithFlow.getPublish().createStateful(NO_PACKET_IDENTIFIER_QOS_0, false, topicAliasMapping),
+        ctx.write(publishWithFlow.getPublish().createStateful(NO_PACKET_IDENTIFIER_QOS_0, false, topicAliasMapping),
                 new DefaultContextPromise<>(ctx.channel(), publishWithFlow)).addListener(this);
     }
 
@@ -291,8 +289,7 @@ private void writeQos1Or2Publish(
         pendingIndex.put(publishWithFlow);
         pending.add(publishWithFlow);
 
-        writeQos1Or2Publish(
-                ctx,
+        writeQos1Or2Publish(ctx,
                 publishWithFlow.getPublish().createStateful(packetIdentifier, false, topicAliasMapping),
                 publishWithFlow);
     }

Diff for: src/main/java/com/hivemq/client/mqtt/mqtt5/message/publish/Mqtt5PayloadFormatIndicator.java

@@ -32,7 +32,8 @@ public enum Mqtt5PayloadFormatIndicator {
      */
     UNSPECIFIED,
     /**
-     * Payload consists of UTF-8 encoded character data as defined by the Unicode specification and restated in RFC 3629.
+     * Payload consists of UTF-8 encoded character data as defined by the Unicode specification and restated in RFC
+     * 3629.
      */
     UTF_8;