Skip to content

Commit

Permalink
Correct Message Queue log statements now that queues are per from-to …
Browse files Browse the repository at this point in the history
…pairs
  • Loading branch information
kayabaNerve committed Sep 28, 2023
1 parent 7d738a3 commit aa1faef
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions message-queue/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ mod binaries {
},
);

log::info!("Queued message from {:?}. It is {:?} {id}", meta.from, meta.to);
log::info!("Queued message. From: {:?} To: {:?} ID: {id}", meta.from, meta.to);
DbTxn::commit(txn);
}

Expand Down Expand Up @@ -142,7 +142,7 @@ mod binaries {
// It's the second if we acknowledge messages before saving them as acknowledged
// TODO: Check only a proper message is being acked

log::info!("{:?} is acknowledging {:?} {}", from, to, id);
log::info!("Acknowledging From: {:?} To: {:?} ID: {}", from, to, id);

(*QUEUES).read().unwrap()[&(from, to)].write().unwrap().ack_message(id)
}
Expand Down

0 comments on commit aa1faef

Please sign in to comment.