Improve trace log

nats-io · Oct 31, 2022 · d1bf472 · d1bf472
1 parent 46b96aa
commit d1bf472
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/async-nats/src/client.rs b/async-nats/src/client.rs
@@ -279,7 +279,7 @@ impl Client {
     /// # }
     /// ```
     pub async fn request(&self, subject: String, payload: Bytes) -> Result<Message, Error> {
-        trace!("request sent to subject: {}", subject);
+        trace!("request sent to subject: {} ({})", subject, payload.len());
         let request = Request::new().payload(payload);
         self.send_request(subject, request).await
     }

diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs
@@ -241,6 +241,7 @@ impl Context {
                 })
             }
         }
+
         if let Some(ref mut sources) = config.sources {
             for source in sources {
                 if let Some(ref mut domain) = source.domain {