Ecosystem/serai
Ecosystem/serai
1
0
Fork 0
mirror of https://github.com/serai-dex/serai.git synced 2025-01-03 09:29:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Correct Message Queue log statements now that queues are per from-to pairs

Browse source
This commit is contained in:
Luke Parker 2023-09-27 21:00:07 -04:00
parent 7d738a3677
commit aa1faefe33
No known key found for this signature in database
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
message-queue/src/main.rs
View file

@ -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); DbTxn::commit(txn);
} }
@ -142,7 +142,7 @@ mod binaries {
// It's the second if we acknowledge messages before saving them as acknowledged // It's the second if we acknowledge messages before saving them as acknowledged
// TODO: Check only a proper message is being acked // 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) (*QUEUES).read().unwrap()[&(from, to)].write().unwrap().ack_message(id)
} }