Skip to content

Commit

Permalink
Improve trace log
Browse files Browse the repository at this point in the history
  • Loading branch information
Jarema committed Oct 28, 2022
1 parent 60a8b1d commit 96e9de2
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
2 changes: 1 addition & 1 deletion async-nats/src/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down
1 change: 1 addition & 0 deletions async-nats/src/jetstream/context.rs
Original file line number Diff line number Diff line change
Expand Up @@ -213,6 +213,7 @@ impl Context {
})
}
}

if let Some(ref mut sources) = config.sources {
for source in sources {
if let Some(ref mut domain) = source.domain {
Expand Down

0 comments on commit 96e9de2

Please sign in to comment.