[ISSUE #1207]🔥Rename rocketmq-client crate name to rocketmq-client-rust🐛 (#1208)

Author: mxsm

Cargo.lock

@@ -38,7 +38,7 @@ rocketmq-remoting = { version = "0.3.0", path = "./rocketmq-remoting" }
 rocketmq-cli = { version = "0.3.0", path = "./rocketmq-cli" }
 rocketmq-namesrv = { version = "0.3.0", path = "./rocketmq-namesrv" }
 rocketmq-broker = { version = "0.3.0", path = "./rocketmq-broker" }
-rocketmq-client = { version = "0.3.0", path = "./rocketmq-client" }
+rocketmq-client-rust = { version = "0.3.0", path = "./rocketmq-client" }
 
 tokio = { version = "1.41", features = ["full"] }
 tokio-util = { version = "0.7.12", features = ["full"] }

Cargo.toml

@@ -24,7 +24,7 @@ rocketmq-store = { workspace = true }
 rocketmq-filter = { workspace = true }
 rocketmq-macros = { workspace = true }
 rocketmq-runtime = { workspace = true }
-rocketmq-client = { workspace = true }
+rocketmq-client-rust = { workspace = true }
 
 anyhow.workspace = true
 env_logger.workspace = true

rocketmq-broker/Cargo.toml

@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-use rocketmq_client::consumer::pull_result::PullResult;
+use rocketmq_client_rust::consumer::pull_result::PullResult;
 use rocketmq_common::common::message::message_ext::MessageExt;
 
 pub(crate) struct GetResult {

rocketmq-broker/src/transaction/queue/get_result.rs

@@ -21,8 +21,8 @@ use std::sync::Arc;
 
 use bytes::Bytes;
 use cheetah_string::CheetahString;
-use rocketmq_client::consumer::pull_result::PullResult;
-use rocketmq_client::consumer::pull_status::PullStatus;
+use rocketmq_client_rust::consumer::pull_result::PullResult;
+use rocketmq_client_rust::consumer::pull_status::PullStatus;
 use rocketmq_common::common::broker::broker_config::BrokerConfig;
 use rocketmq_common::common::config::TopicConfig;
 use rocketmq_common::common::constant::PermName;

rocketmq-broker/src/transaction/queue/transactional_message_bridge.rs

@@ -1,5 +1,5 @@
 [package]
-name = "rocketmq-client"
+name = "rocketmq-client-rust"
 version.workspace = true
 authors.workspace = true
 edition.workspace = true

rocketmq-client/Cargo.toml

@@ -19,9 +19,9 @@ First, start the RocketMQ NameServer and Broker services.
 ### Send a single message
 
 ```rust
-use rocketmq_client::producer::default_mq_producer::DefaultMQProducer;
-use rocketmq_client::producer::mq_producer::MQProducer;
-use rocketmq_client::Result;
+use rocketmq_client_rust::producer::default_mq_producer::DefaultMQProducer;
+use rocketmq_client_rust::producer::mq_producer::MQProducer;
+use rocketmq_client_rust::Result;
 use rocketmq_common::common::message::message_single::Message;
 use rocketmq_rust::rocketmq;
 
@@ -61,8 +61,8 @@ pub async fn main() -> Result<()> {
 ### Send batch messages
 
 ```rust
-use rocketmq_client::producer::default_mq_producer::DefaultMQProducer;
-use rocketmq_client::producer::mq_producer::MQProducer;
+use rocketmq_client_rust::producer::default_mq_producer::DefaultMQProducer;
+use rocketmq_client_rust::producer::mq_producer::MQProducer;
 use rocketmq_common::common::message::message_single::Message;
 use rocketmq_rust::rocketmq;
 
@@ -72,7 +72,7 @@ pub const TOPIC: &str = "TopicTest";
 pub const TAG: &str = "TagA";
 
 #[rocketmq::main]
-pub async fn main() -> rocketmq_client::Result<()> {
+pub async fn main() -> rocketmq_client_rust::Result<()> {
     //init logger
     rocketmq_common::log::init_logger();
 
@@ -113,9 +113,9 @@ pub async fn main() -> rocketmq_client::Result<()> {
 ### Send RPC messages
 
 ```rust
-use rocketmq_client::producer::default_mq_producer::DefaultMQProducer;
-use rocketmq_client::producer::mq_producer::MQProducer;
-use rocketmq_client::Result;
+use rocketmq_client_rust::producer::default_mq_producer::DefaultMQProducer;
+use rocketmq_client_rust::producer::mq_producer::MQProducer;
+use rocketmq_client_rust::Result;
 use rocketmq_common::common::message::message_single::Message;
 use rocketmq_rust::rocketmq;
 

rocketmq-client/README.md

@@ -18,8 +18,8 @@ use std::sync::atomic::AtomicI32;
 use std::sync::Arc;
 use std::thread::sleep;
 
-use rocketmq_client::producer::default_mq_producer::DefaultMQProducer;
-use rocketmq_client::producer::mq_producer::MQProducer;
+use rocketmq_client_rust::producer::default_mq_producer::DefaultMQProducer;
+use rocketmq_client_rust::producer::mq_producer::MQProducer;
 use rocketmq_common::common::message::message_single::Message;
 use rocketmq_rust::rocketmq;
 use tracing::info;
@@ -30,7 +30,7 @@ pub const TOPIC: &str = "TopicTest";
 pub const TAG: &str = "TagA";
 
 #[rocketmq::main]
-pub async fn main() -> rocketmq_client::Result<()> {
+pub async fn main() -> rocketmq_client_rust::Result<()> {
     //init logger
     rocketmq_common::log::init_logger();
 

rocketmq-client/examples/batch/callback_batch_producer.rs

@@ -14,8 +14,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-use rocketmq_client::producer::default_mq_producer::DefaultMQProducer;
-use rocketmq_client::producer::mq_producer::MQProducer;
+use rocketmq_client_rust::producer::default_mq_producer::DefaultMQProducer;
+use rocketmq_client_rust::producer::mq_producer::MQProducer;
 use rocketmq_common::common::message::message_single::Message;
 use rocketmq_rust::rocketmq;
 
@@ -25,7 +25,7 @@ pub const TOPIC: &str = "TopicTest";
 pub const TAG: &str = "TagA";
 
 #[rocketmq::main]
-pub async fn main() -> rocketmq_client::Result<()> {
+pub async fn main() -> rocketmq_client_rust::Result<()> {
     //init logger
     rocketmq_common::log::init_logger();
 

rocketmq-client/examples/batch/simple_batch_producer.rs

@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-use rocketmq_client::consumer::default_mq_push_consumer::DefaultMQPushConsumer;
-use rocketmq_client::consumer::listener::consume_concurrently_context::ConsumeConcurrentlyContext;
-use rocketmq_client::consumer::listener::consume_concurrently_status::ConsumeConcurrentlyStatus;
-use rocketmq_client::consumer::listener::message_listener_concurrently::MessageListenerConcurrently;
-use rocketmq_client::consumer::mq_push_consumer::MQPushConsumer;
-use rocketmq_client::Result;
+use rocketmq_client_rust::consumer::default_mq_push_consumer::DefaultMQPushConsumer;
+use rocketmq_client_rust::consumer::listener::consume_concurrently_context::ConsumeConcurrentlyContext;
+use rocketmq_client_rust::consumer::listener::consume_concurrently_status::ConsumeConcurrentlyStatus;
+use rocketmq_client_rust::consumer::listener::message_listener_concurrently::MessageListenerConcurrently;
+use rocketmq_client_rust::consumer::mq_push_consumer::MQPushConsumer;
+use rocketmq_client_rust::Result;
 use rocketmq_common::common::consumer::consume_from_where::ConsumeFromWhere;
 use rocketmq_common::common::message::message_ext::MessageExt;
 use rocketmq_remoting::protocol::heartbeat::message_model::MessageModel;