Skip to content

Commit 9fecafe

Browse files
authored
[ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954)
1 parent ae69814 commit 9fecafe

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2853,7 +2853,7 @@ private RemotingCommand resumeCheckHalfMessage(ChannelHandlerContext ctx,
28532853
MessageId messageId = MessageDecoder.decodeMessageId(requestHeader.getMsgId());
28542854
selectMappedBufferResult = this.brokerController.getMessageStore()
28552855
.selectOneMessageByOffset(messageId.getOffset());
2856-
MessageExt msg = MessageDecoder.decode(selectMappedBufferResult.getByteBuffer());
2856+
MessageExt msg = MessageDecoder.decode(selectMappedBufferResult.getByteBuffer(), true, false);
28572857
msg.putUserProperty(MessageConst.PROPERTY_TRANSACTION_CHECK_TIMES, String.valueOf(0));
28582858
PutMessageResult putMessageResult = this.brokerController.getMessageStore()
28592859
.putMessage(toMessageExtBrokerInner(msg));

0 commit comments

Comments
 (0)