[ISSUE #2386]🔍️Optimize Connection#send_command performance 🚀

mxsm · Jan 24, 2025 · 2ec3924 · 2ec3924
1 parent 9def069
commit 2ec3924
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/rocketmq-remoting/src/connection.rs b/rocketmq-remoting/src/connection.rs
@@ -142,8 +142,8 @@ impl Connection {
     ) -> Result<(), RemotingError> {
         self.buf.clear();
         command.fast_header_encode(&mut self.buf);
-        if let Some(body_inner) = command.get_body() {
-            self.buf.put(body_inner.as_ref());
+        if let Some(body_inner) = command.take_body() {
+            self.buf.put(body_inner);
         }
         self.writer.send(self.buf.clone()).await?;
         Ok(())