fixes

Signed-off-by: Oleh Dokuka <odokuka@vmware.com>
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
Signed-off-by: OlegDokuka <odokuka@vmware.com>

Author: OlegDokuka

rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/TcpDuplexConnection.java

@@ -25,6 +25,7 @@
 import io.rsocket.internal.BaseDuplexConnection;
 import java.net.SocketAddress;
 import java.util.Objects;
+import java.util.logging.Level;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import reactor.core.publisher.BaseSubscriber;
@@ -50,7 +51,17 @@ public TcpDuplexConnection(Connection connection) {
 
     connection.channel().closeFuture().addListener(future -> sender.dispose());
 
-    connection.outbound().send(sender.log("queue " + this)).then().subscribe();
+    connection
+        .outbound()
+        .send(
+            sender.log(
+                "queue " + this,
+                Level.INFO,
+                SignalType.CANCEL,
+                SignalType.ON_ERROR,
+                SignalType.ON_COMPLETE))
+        .then()
+        .subscribe();
   }
 
   @Override

rsocket-transport-netty/src/main/java/io/rsocket/transport/netty/WebsocketDuplexConnection.java

@@ -24,6 +24,7 @@
 import io.rsocket.internal.BaseDuplexConnection;
 import java.net.SocketAddress;
 import java.util.Objects;
+import java.util.logging.Level;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import reactor.core.publisher.BaseSubscriber;
@@ -56,7 +57,15 @@ public WebsocketDuplexConnection(Connection connection) {
 
     connection
         .outbound()
-        .sendObject(sender.map(BinaryWebSocketFrame::new).log("queue " + this))
+        .sendObject(
+            sender
+                .map(BinaryWebSocketFrame::new)
+                .log(
+                    "queue " + this,
+                    Level.INFO,
+                    SignalType.CANCEL,
+                    SignalType.ON_ERROR,
+                    SignalType.ON_COMPLETE))
         .then()
         .subscribe();
   }