Merge remote-tracking branch 'origin/develop' into feature/138-update-the-main-readme

Author: JavaSaBr

gradle/libs.versions.toml

@@ -1,6 +1,6 @@
 [versions]
 # https://gitlab.com/JavaSaBr/maven-repo/-/packages
-rlib = "10.0.alpha8"
+rlib = "10.0.alpha9"
 # https://mvnrepository.com/artifact/org.projectlombok/lombok
 lombok = "1.18.38"
 # https://mvnrepository.com/artifact/org.jspecify/jspecify

network/src/main/java/javasabr/mqtt/network/impl/AbstractNetworkMqttUser.java

@@ -16,14 +16,12 @@
 import lombok.CustomLog;
 import lombok.Getter;
 import lombok.Setter;
-import lombok.experimental.Accessors;
 import lombok.experimental.FieldDefaults;
 import org.jspecify.annotations.Nullable;
 import reactor.core.publisher.Mono;
 
 @Getter
 @CustomLog
-@Accessors(fluent = true, chain = false)
 @FieldDefaults(level = AccessLevel.PROTECTED)
 public abstract class AbstractNetworkMqttUser implements ConfigurableNetworkMqttUser {
 
@@ -65,7 +63,7 @@ public void sendInBackground(SendableMqttMessage message) {
   @Override
   public void sendInBackground(MqttOutMessage message) {
     log.debug(clientId, message.name(), message, "[%s] Send message to user:[%s] %s"::formatted);
-    connection.send(message);
+    connection.sendInBackground(message);
   }
 
   @Override
@@ -76,7 +74,7 @@ public CompletionStage<Boolean> sendAsync(SendableMqttMessage message) {
   @Override
   public CompletableFuture<Boolean> sendAsync(MqttOutMessage message) {
     log.debug(clientId, message.name(), message, "[%s] Send message to user:[%s] %s"::formatted);
-    return connection.sendWithFeedback(message);
+    return connection.sendAsync(message);
   }
 
   @Override
@@ -91,7 +89,7 @@ public CompletableFuture<Boolean> closeWithReason(MqttOutMessage message) {
   @Override
   public void reject(ConnectAckMqtt311OutMessage connectAsk) {
     connection
-        .sendWithFeedback(connectAsk)
+        .sendAsync(connectAsk)
         .thenAccept(_ -> connection.close());
   }