set RUST_LOG if unset

Signed-off-by: Marc-Antoine Perennou <Marc-Antoine@Perennou.com>
amqp-rs · May 25, 2020 · 1d3e730 · 1d3e730
1 parent ae196be
commit 1d3e730
Show file tree

Hide file tree

Showing 12 changed files with 42 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -51,6 +51,10 @@ use log::info;
 use std::sync::Arc;
 
 fn main() -> Result<()> {
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
+
     env_logger::init();
 
     let addr = std::env::var("AMQP_ADDR").unwrap_or_else(|_| "amqp://127.0.0.1:5672/%2f".into());

diff --git a/async-std/examples/pubsub-async-std.rs b/async-std/examples/pubsub-async-std.rs
@@ -8,6 +8,10 @@ use std::sync::Arc;
 
 #[async_std::main]
 async fn main() -> Result<()> {
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
+
     env_logger::init();
 
     let addr = std::env::var("AMQP_ADDR").unwrap_or_else(|_| "amqp://127.0.0.1:5672/%2f".into());

diff --git a/examples/client-certificate.rs b/examples/client-certificate.rs
@@ -29,6 +29,10 @@ fn get_tls_config() -> TLSConfig<'static, 'static, 'static> {
 }
 
 fn main() {
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
+
     env_logger::init();
 
     let addr = std::env::var("AMQP_ADDR")

diff --git a/examples/connection.rs b/examples/connection.rs
@@ -7,7 +7,9 @@ use log::info;
 use std::sync::Arc;
 
 fn main() {
-    std::env::set_var("RUST_LOG", "trace");
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
 
     env_logger::init();
 

diff --git a/examples/consumer.rs b/examples/consumer.rs
@@ -3,7 +3,9 @@ use lapin::{options::*, types::FieldTable, Connection, ConnectionProperties};
 use log::info;
 
 fn main() {
-    std::env::set_var("RUST_LOG", "info");
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
 
     env_logger::init();
 

diff --git a/examples/custom_tls_connection.rs b/examples/custom_tls_connection.rs
@@ -43,7 +43,9 @@ async fn connect() -> Result<Connection> {
 }
 
 fn main() {
-    std::env::set_var("RUST_LOG", "info");
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
 
     env_logger::init();
 

diff --git a/examples/publisher_confirms.rs b/examples/publisher_confirms.rs
@@ -9,7 +9,9 @@ use log::info;
 use std::sync::Arc;
 
 fn main() {
-    std::env::set_var("RUST_LOG", "info");
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
 
     env_logger::init();
 

diff --git a/examples/pubsub.rs b/examples/pubsub.rs
@@ -8,7 +8,9 @@ use log::info;
 use std::sync::Arc;
 
 fn main() -> Result<()> {
-    std::env::set_var("RUST_LOG", "info");
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
 
     env_logger::init();
 

diff --git a/examples/pubsub_nofutures.rs b/examples/pubsub_nofutures.rs
@@ -28,7 +28,9 @@ impl ConsumerDelegate for Subscriber {
 }
 
 fn main() {
-    std::env::set_var("RUST_LOG", "info");
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
 
     env_logger::init();
 

diff --git a/lapinou/examples/pubsub-smol.rs b/lapinou/examples/pubsub-smol.rs
@@ -8,6 +8,10 @@ use log::info;
 use std::sync::Arc;
 
 fn main() -> Result<()> {
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
+
     env_logger::init();
 
     let addr = std::env::var("AMQP_ADDR").unwrap_or_else(|_| "amqp://127.0.0.1:5672/%2f".into());

diff --git a/src/lib.rs b/src/lib.rs
@@ -25,6 +25,10 @@
 //! use std::sync::Arc;
 //!
 //! fn main() -> Result<()> {
+//!     if std::env::var("RUST_LOG").is_err() {
+//!         std::env::set_var("RUST_LOG", "info");
+//!     }
+//!
 //!     env_logger::init();
 //!
 //!     let addr = std::env::var("AMQP_ADDR").unwrap_or_else(|_| "amqp://127.0.0.1:5672/%2f".into());

diff --git a/tokio/examples/pubsub-tokio.rs b/tokio/examples/pubsub-tokio.rs
@@ -8,6 +8,10 @@ use tokio_amqp::*;
 
 #[tokio::main]
 async fn main() -> Result<()> {
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "info");
+    }
+
     env_logger::init();
 
     let addr = std::env::var("AMQP_ADDR").unwrap_or_else(|_| "amqp://127.0.0.1:5672/%2f".into());