[ISSUE #2372]👻Channel add send method🚀 (#2373)

mxsm · Jan 23, 2025 · 7711374 · 7711374
1 parent a5f472b
commit 7711374
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/rocketmq-remoting/src/net/channel.rs b/rocketmq-remoting/src/net/channel.rs
@@ -244,6 +244,15 @@ impl Channel {
         }
         Ok(())
     }
+
+    pub async fn send(&mut self, request: RemotingCommand) -> Result<()> {
+        let request = request.mark_oneway_rpc();
+        if let Err(err) = self.tx.send((request, None, None)).await {
+            error!("send request failed: {}", err);
+            return Err(ChannelSendRequestFailed(err.to_string()));
+        }
+        Ok(())
+    }
 }
 
 #[cfg(test)]