fixes

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

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

@@ -56,7 +56,7 @@ public TcpDuplexConnection(Connection connection) {
     //              if (!isDisposed()) dispose();
     //            });
 
-    connection.outbound().send(sender).then().subscribe();
+    connection.outbound().send(sender.log("queue " + this)).then().subscribe();
   }
 
   @Override

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

@@ -60,7 +60,7 @@ public WebsocketDuplexConnection(Connection connection) {
     //              if (!isDisposed()) dispose();
     //            });
 
-    connection.outbound().sendObject(sender.map(BinaryWebSocketFrame::new)).then().subscribe();
+    connection.outbound().sendObject(sender.map(BinaryWebSocketFrame::new).log("queue " + this)).then().subscribe();
   }
 
   @Override