[broker-23] add NotNull annotations to fields

Author: crazyrokr

src/main/java/com/ss/mqtt/broker/model/MqttVersion.java

@@ -62,10 +62,10 @@ public enum MqttVersion {
         return availableVersions[level];
     }
 
-    private final String name;
-    private final byte[] nameInBytes;
+    private final @NotNull MqttPacketOutFactory packetOutFactory;
+    private final byte @NotNull [] nameInBytes;
+    private final @NotNull String name;
     private final byte version;
-    private final MqttPacketOutFactory packetOutFactory;
 
     MqttVersion(@NotNull String name, int version, @NotNull MqttPacketOutFactory packetOutFactory) {
         this.name = name;

src/main/java/com/ss/mqtt/broker/model/PacketProperty.java

@@ -64,8 +64,8 @@ public enum PacketProperty {
     }
 
     private final @Getter byte id;
-    private final @Getter PacketDataType dataType;
-    private final Object defaultValue;
+    private final @Getter @NotNull PacketDataType dataType;
+    private final @Nullable Object defaultValue;
 
     PacketProperty(int id, @NotNull PacketDataType dataType) {
         this(id, dataType, null);

src/main/java/com/ss/mqtt/broker/model/SharedSubscriber.java

@@ -13,8 +13,8 @@
 public class SharedSubscriber implements Subscriber {
 
     private final @NotNull SharedTopicFilter topicFilter;
-    private final ConcurrentArray<SingleSubscriber> subscribers;
-    private final AtomicInteger current;
+    private final @NotNull ConcurrentArray<SingleSubscriber> subscribers;
+    private final @NotNull AtomicInteger current;
 
     public SharedSubscriber(@NotNull SubscribeTopicFilter topic) {
         subscribers = ConcurrentArray.ofType(Subscriber.class);

src/main/java/com/ss/mqtt/broker/model/data/type/StringPair.java

@@ -4,13 +4,14 @@
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import lombok.ToString;
+import org.jetbrains.annotations.NotNull;
 
 @Getter
 @ToString
 @EqualsAndHashCode
 @RequiredArgsConstructor
 public class StringPair {
 
-    private final String name;
-    private final String value;
+    private final @NotNull String name;
+    private final @NotNull String value;
 }

src/main/java/com/ss/mqtt/broker/network/client/AbstractMqttClient.java

@@ -32,8 +32,8 @@ public abstract class AbstractMqttClient implements UnsafeMqttClient {
     }
 
     protected final @NotNull MqttConnection connection;
-    protected final MqttClientReleaseHandler releaseHandler;
-    protected final AtomicBoolean released;
+    protected final @NotNull MqttClientReleaseHandler releaseHandler;
+    protected final @NotNull AtomicBoolean released;
 
     private volatile @Setter @NotNull String clientId;
     private volatile @Setter @Getter @Nullable MqttSession session;

src/main/java/com/ss/mqtt/broker/service/impl/FileCredentialsSource.java

@@ -12,7 +12,7 @@
 
 public class FileCredentialsSource extends AbstractCredentialSource {
 
-    private final String fileName;
+    private final @NotNull String fileName;
 
     public FileCredentialsSource(@NotNull String fileName) {
         this.fileName = fileName;

src/main/java/com/ss/mqtt/broker/service/impl/SimpleSubscriptionService.java

@@ -23,7 +23,7 @@
  */
 public class SimpleSubscriptionService implements SubscriptionService {
 
-    private final TopicSubscribers topicSubscribers = new TopicSubscribers();
+    private final @NotNull TopicSubscribers topicSubscribers = new TopicSubscribers();
 
     @Override
     public <A> @NotNull ActionResult forEachTopicSubscriber(