Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

12 changes: 8 additions & 4 deletions rocketmq-client/examples/batch/callback_batch_producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";
pub const TAG: &str = "TagA";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQProducer::builder();

Expand Down Expand Up @@ -120,5 +119,10 @@ pub async fn main() -> RocketMQResult<()> {
sleep(std::time::Duration::from_secs(6));
let i = counter.load(std::sync::atomic::Ordering::SeqCst);
println!("send message count: {}", i);
telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}
12 changes: 8 additions & 4 deletions rocketmq-client/examples/batch/simple_batch_producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";
pub const TAG: &str = "TagA";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQProducer::builder();

Expand Down Expand Up @@ -59,5 +58,10 @@ pub async fn main() -> RocketMQResult<()> {
];
let send_result = producer.send_batch(messages).await?;
println!("send result: {}", send_result);
telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}
12 changes: 8 additions & 4 deletions rocketmq-client/examples/broadcast/push_consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -33,12 +33,11 @@ pub const TOPIC: &str = "TopicTest";
//pub const SUB_EXPRESSION: &str = "TagA || TagC || TagD";
pub const SUB_EXPRESSION: &str = "*";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQPushConsumer::builder();

Expand All @@ -52,6 +51,11 @@ pub async fn main() -> RocketMQResult<()> {
consumer.register_message_listener_concurrently(MyMessageListener);
consumer.start().await?;
let _ = tokio::signal::ctrl_c().await;
telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}

Expand Down
12 changes: 8 additions & 4 deletions rocketmq-client/examples/consumer/pop_consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,12 +30,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";
pub const TAG: &str = "*";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQPushConsumer::builder();

Expand All @@ -49,6 +48,11 @@ pub async fn main() -> RocketMQResult<()> {
consumer.register_message_listener_concurrently(MyMessageListener);
consumer.start().await?;
let _ = tokio::signal::ctrl_c().await;
telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}

Expand Down
12 changes: 8 additions & 4 deletions rocketmq-client/examples/ordermessage/ordermessage_consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -37,12 +37,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";
pub const TAG: &str = "*";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQPushConsumer::builder();

Expand All @@ -56,6 +55,11 @@ pub async fn main() -> RocketMQResult<()> {
consumer.register_message_listener_orderly(MyMessageListener::new());
consumer.start().await?;
let _ = tokio::signal::ctrl_c().await;
telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}

Expand Down
12 changes: 8 additions & 4 deletions rocketmq-client/examples/ordermessage/ordermessage_producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,11 @@ pub const PRODUCER_GROUP: &str = "please_rename_unique_group_name";
pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQProducer::builder();

Expand Down Expand Up @@ -65,5 +64,10 @@ pub async fn main() -> RocketMQResult<()> {
}
producer.shutdown().await;

telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}
12 changes: 8 additions & 4 deletions rocketmq-client/examples/quickstart/consumer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,12 +30,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";
pub const TAG: &str = "*";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQPushConsumer::builder();

Expand All @@ -47,6 +46,11 @@ pub async fn main() -> RocketMQResult<()> {
consumer.register_message_listener_concurrently(MyMessageListener);
consumer.start().await?;
let _ = tokio::signal::ctrl_c().await;
telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}

Expand Down
12 changes: 8 additions & 4 deletions rocketmq-client/examples/quickstart/producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";
pub const TAG: &str = "TagA";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQProducer::builder();

Expand All @@ -51,5 +50,10 @@ pub async fn main() -> RocketMQResult<()> {
}
producer.shutdown().await;

telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}
12 changes: 8 additions & 4 deletions rocketmq-client/examples/rpc/request_callback_producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "RequestTopic";
pub const TAG: &str = "TagA";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQProducer::builder();

Expand Down Expand Up @@ -58,5 +57,10 @@ pub async fn main() -> RocketMQResult<()> {
let _ = rx.recv().await;
producer.shutdown().await;

telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}
12 changes: 8 additions & 4 deletions rocketmq-client/examples/rpc/request_producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "RequestTopic";
pub const TAG: &str = "TagA";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = DefaultMQProducer::builder();

Expand All @@ -52,5 +51,10 @@ pub async fn main() -> RocketMQResult<()> {
println!("send result: {:?}", message);
producer.shutdown().await;

telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}
12 changes: 8 additions & 4 deletions rocketmq-client/examples/transaction/transaction_producer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,11 @@ pub const DEFAULT_NAMESRVADDR: &str = "127.0.0.1:9876";
pub const TOPIC: &str = "TopicTest";
pub const TAG: &str = "TagA";

#[allow(deprecated)]
#[rocketmq::main]
pub async fn main() -> RocketMQResult<()> {
//init logger
rocketmq_common::log::init_logger()?;

let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");
// create a producer builder with default configuration
let builder = TransactionMQProducer::builder();

Expand All @@ -64,6 +63,11 @@ pub async fn main() -> RocketMQResult<()> {
let _ = tokio::signal::ctrl_c().await;
producer.shutdown().await;

telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}

Expand Down
12 changes: 8 additions & 4 deletions rocketmq-controller/examples/controller_manager_basic.rs
Original file line number Diff line number Diff line change
Expand Up @@ -34,13 +34,12 @@ use rocketmq_controller::manager::ControllerManager;
use rocketmq_rust::ArcMut;
use tracing::error;
use tracing::info;
use tracing_subscriber::fmt;
use tracing_subscriber::prelude::*;

#[tokio::main]
async fn main() -> Result<()> {
// Initialize logging
tracing_subscriber::registry().with(fmt::layer()).init();
let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");

info!("Starting ControllerManager example");

Expand Down Expand Up @@ -87,6 +86,11 @@ async fn main() -> Result<()> {
manager.shutdown().await?;
info!(" Controller shut down successfully");

telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}

Expand Down
12 changes: 8 additions & 4 deletions rocketmq-controller/examples/controller_manager_cluster.rs
Original file line number Diff line number Diff line change
Expand Up @@ -36,13 +36,12 @@ use rocketmq_rust::ArcMut;
use tracing::error;
use tracing::info;
use tracing::warn;
use tracing_subscriber::fmt;
use tracing_subscriber::prelude::*;

#[tokio::main]
async fn main() -> Result<()> {
// Initialize logging
tracing_subscriber::registry().with(fmt::layer()).init();
let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())
.expect("telemetry logging bootstrap should initialize");

info!("Starting 3-node ControllerManager cluster example");

Expand All @@ -65,6 +64,11 @@ async fn main() -> Result<()> {
shutdown_cluster(managers).await?;

info!("Cluster shutdown complete");
telemetry_guard
.shutdown()
.into_result()
.expect("telemetry logging shutdown should succeed");

Ok(())
}

Expand Down
4 changes: 3 additions & 1 deletion rocketmq-controller/examples/three_node_cluster.rs
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,8 @@ struct Args {
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let args = Args::parse();
tracing_subscriber::fmt().with_max_level(tracing::Level::INFO).init();
let telemetry_guard =
rocketmq_observability::install_global(&rocketmq_observability::TelemetryBootstrapConfig::default())?;

let peers = vec![
RaftPeer {
Expand Down Expand Up @@ -129,5 +130,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
tokio::signal::ctrl_c().await?;

node.shutdown().await?;
telemetry_guard.shutdown().into_result()?;
Ok(())
}
Loading
Loading