(rocketmq) branch develop updated: [ISSUE #7676] use clientDecode for consuming message directly (#7677)

[cserwen]

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

cserwen 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 c10121697a [ISSUE #7676] use clientDecode for consuming message 
directly (#7677)
c10121697a is described below

commit c10121697ae50ad19ac0dea1ef22690caba14e99
Author: cserwen <cser...@apache.org>
AuthorDate: Wed Dec 20 10:12:15 2023 +0800

    [ISSUE #7676] use clientDecode for consuming message directly (#7677)
    
    Co-authored-by: dengzhiwen1 <dengzhiw...@xiaomi.com>
---
 .../java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
index 31b879ffed..2f18c610c1 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
@@ -208,7 +208,7 @@ public class ClientRemotingProcessor implements 
NettyRequestProcessor {
             (ConsumeMessageDirectlyResultRequestHeader) request
                 
.decodeCommandCustomHeader(ConsumeMessageDirectlyResultRequestHeader.class);
 
-        final MessageExt msg = 
MessageDecoder.decode(ByteBuffer.wrap(request.getBody()));
+        final MessageExt msg = 
MessageDecoder.clientDecode(ByteBuffer.wrap(request.getBody()), true);
 
         ConsumeMessageDirectlyResult result =
             this.mqClientFactory.consumeMessageDirectly(msg, 
requestHeader.getConsumerGroup(), requestHeader.getBrokerName());