This is an automated email from the ASF dual-hosted git repository.

caigy pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new d2818da816 remove unnecessary type cast (#7971)
d2818da816 is described below

commit d2818da816edead05678de1839a53ed4cb6c2b39
Author: ChineseTony <[email protected]>
AuthorDate: Thu Mar 28 20:34:04 2024 +0800

    remove unnecessary type cast (#7971)
---
 .../org/apache/rocketmq/remoting/netty/NettyServerConfig.java     | 2 +-
 .../remoting/protocol/header/SendMessageRequestHeader.java        | 8 ++------
 2 files changed, 3 insertions(+), 7 deletions(-)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
index 756661f623..6564404b92 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
@@ -156,7 +156,7 @@ public class NettyServerConfig implements Cloneable {
 
     @Override
     public Object clone() throws CloneNotSupportedException {
-        return (NettyServerConfig) super.clone();
+        return super.clone();
     }
 
     public int getWriteBufferLowWaterMark() {
diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java
index a0a1464e35..2857fb516a 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java
@@ -188,14 +188,10 @@ public class SendMessageRequestHeader extends 
TopicQueueRequestHeader {
         switch (request.getCode()) {
             case RequestCode.SEND_BATCH_MESSAGE:
             case RequestCode.SEND_MESSAGE_V2:
-                requestHeaderV2 =
-                    (SendMessageRequestHeaderV2) request
-                        
.decodeCommandCustomHeader(SendMessageRequestHeaderV2.class);
+                requestHeaderV2 = 
request.decodeCommandCustomHeader(SendMessageRequestHeaderV2.class);
             case RequestCode.SEND_MESSAGE:
                 if (null == requestHeaderV2) {
-                    requestHeader =
-                        (SendMessageRequestHeader) request
-                            
.decodeCommandCustomHeader(SendMessageRequestHeader.class);
+                    requestHeader = 
request.decodeCommandCustomHeader(SendMessageRequestHeader.class);
                 } else {
                     requestHeader = 
SendMessageRequestHeaderV2.createSendMessageRequestHeaderV1(requestHeaderV2);
                 }

Reply via email to