logs

Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
rsocket · Mar 28, 2023 · 1542a2a · 1542a2a
1 parent 9d5e8fa
commit 1542a2a
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/rsocket-transport-netty/src/main/java/reactor/netty/channel/FluxReceive.java b/rsocket-transport-netty/src/main/java/reactor/netty/channel/FluxReceive.java
@@ -148,10 +148,11 @@ public void subscribe(CoreSubscriber<? super Object> s) {
   }
 
   final void startReceiver(CoreSubscriber<? super Object> s) {
+    log.info(format(channel, "{}: subscribing before inbound receiver {}"), this, s);
     if (once == 0 && ONCE.compareAndSet(this, 0, 1)) {
-      if (log.isDebugEnabled()) {
-        log.debug(format(channel, "{}: subscribing inbound receiver"), this);
-      }
+      //      if (log.isDebugEnabled()) {
+      log.info(format(channel, "{}: subscribing inbound receiver"), this);
+      //      }
       if (inboundDone && getPending() == 0) {
         if (inboundError != null) {
           Operators.error(s, inboundError);
@@ -472,7 +473,7 @@ final void onInboundError(Throwable err) {
   }
 
   final void terminateReceiver(@Nullable Queue<?> q, CoreSubscriber<?> a) {
-    log.info("terminating");
+    log.info("terminating " + a);
     if (q != null) {
       q.clear();
     }