[ISSUE #7131] Replace java.nio.ByteBuffer with class name

apache · Aug 8, 2023 · 0d9cbcd · 0d9cbcd
1 parent 3a6ef04
commit 0d9cbcd
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
@@ -388,18 +388,18 @@ public static MessageExt decode(
     }
 
     public static MessageExt decode(
-        java.nio.ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient) {
+        ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient) {
         return decode(byteBuffer, readBody, deCompressBody, isClient, false, false);
     }
 
     public static MessageExt decode(
-        java.nio.ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
+        ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
         final boolean isSetPropertiesString) {
         return decode(byteBuffer, readBody, deCompressBody, isClient, isSetPropertiesString, false);
     }
 
     public static MessageExt decode(
-        java.nio.ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
+        ByteBuffer byteBuffer, final boolean readBody, final boolean deCompressBody, final boolean isClient,
         final boolean isSetPropertiesString, final boolean checkCRC) {
         try {
 

diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java
@@ -86,7 +86,7 @@ public int getMagicCode() {
 
     public abstract int getTopicLengthSize();
 
-    public abstract int getTopicLength(java.nio.ByteBuffer buffer);
-    public abstract int getTopicLength(java.nio.ByteBuffer buffer, int index);
-    public abstract void putTopicLength(java.nio.ByteBuffer buffer, int topicLength);
+    public abstract int getTopicLength(ByteBuffer buffer);
+    public abstract int getTopicLength(ByteBuffer buffer, int index);
+    public abstract void putTopicLength(ByteBuffer buffer, int topicLength);
 }
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -387,7 +387,7 @@ else if (!dispatchRequest.isSuccess()) {
         }
     }
 
-    public DispatchRequest checkMessageAndReturnSize(java.nio.ByteBuffer byteBuffer, final boolean checkCRC,
+    public DispatchRequest checkMessageAndReturnSize(ByteBuffer byteBuffer, final boolean checkCRC,
         final boolean checkDupInfo) {
         return this.checkMessageAndReturnSize(byteBuffer, checkCRC, checkDupInfo, true);
     }
@@ -403,7 +403,7 @@ private void doNothingForDeadCode(final Object obj) {
      *
      * @return 0 Come the end of the file // >0 Normal messages // -1 Message checksum failure
      */
-    public DispatchRequest checkMessageAndReturnSize(java.nio.ByteBuffer byteBuffer, final boolean checkCRC,
+    public DispatchRequest checkMessageAndReturnSize(ByteBuffer byteBuffer, final boolean checkCRC,
         final boolean checkDupInfo, final boolean readBody) {
         try {
             // 1 TOTAL SIZE