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);
}