⚡

TAKETODAY · Dec 16, 2024 · 740f090 · 740f090
1 parent 1519541
commit 740f090
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 8 deletions.
diff --git a/today-core/src/main/java/infra/core/io/buffer/DataBufferUtils.java b/today-core/src/main/java/infra/core/io/buffer/DataBufferUtils.java
@@ -50,8 +50,6 @@
 import infra.lang.Assert;
 import infra.lang.Constant;
 import infra.lang.Nullable;
-import infra.logging.Logger;
-import infra.logging.LoggerFactory;
 import infra.util.ObjectUtils;
 import reactor.core.publisher.BaseSubscriber;
 import reactor.core.publisher.Flux;
@@ -70,8 +68,6 @@
  */
 public abstract class DataBufferUtils {
 
-  final static Logger logger = LoggerFactory.getLogger(DataBufferUtils.class);
-
   //---------------------------------------------------------------------
   // Reading
   //---------------------------------------------------------------------

diff --git a/today-core/src/main/java/infra/core/io/buffer/Netty5DataBuffer.java b/today-core/src/main/java/infra/core/io/buffer/Netty5DataBuffer.java
@@ -24,6 +24,8 @@
 
 import infra.lang.Assert;
 import infra.lang.Nullable;
+import infra.logging.Logger;
+import infra.logging.LoggerFactory;
 import io.netty5.buffer.Buffer;
 import io.netty5.buffer.BufferComponent;
 import io.netty5.buffer.ComponentIterator;
@@ -39,6 +41,8 @@
  */
 public final class Netty5DataBuffer extends DataBuffer implements AutoCloseable {
 
+  private final static Logger logger = LoggerFactory.getLogger(Netty5DataBuffer.class);
+
   private final Buffer buffer;
 
   private final Netty5DataBufferFactory dataBufferFactory;
@@ -305,8 +309,8 @@ public boolean release() {
       this.buffer.close();
     }
     catch (IllegalStateException ex) {
-      if (DataBufferUtils.logger.isDebugEnabled()) {
-        DataBufferUtils.logger.debug("Failed to release DataBuffer {}", this, ex);
+      if (logger.isDebugEnabled()) {
+        logger.debug("Failed to release DataBuffer {}", this, ex);
       }
     }
     return true;

diff --git a/today-core/src/main/java/infra/core/io/buffer/NettyDataBuffer.java b/today-core/src/main/java/infra/core/io/buffer/NettyDataBuffer.java
@@ -25,12 +25,12 @@
 
 import infra.lang.Assert;
 import infra.lang.Nullable;
+import infra.logging.Logger;
+import infra.logging.LoggerFactory;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufUtil;
 import io.netty.buffer.Unpooled;
 
-import static infra.core.io.buffer.DataBufferUtils.logger;
-
 /**
  * Implementation of the {@code DataBuffer} interface that wraps a Netty
  * {@link ByteBuf}. Typically constructed with {@link NettyDataBufferFactory}.
@@ -42,6 +42,8 @@
  */
 public class NettyDataBuffer extends DataBuffer {
 
+  private final static Logger logger = LoggerFactory.getLogger(NettyDataBuffer.class);
+
   private ByteBuf byteBuf;
 
   private final NettyDataBufferFactory dataBufferFactory;