Skip to content

Commit

Permalink
Fix format
Browse files Browse the repository at this point in the history
  • Loading branch information
fulmicoton committed Feb 27, 2024
1 parent 87862af commit bc6a998
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/multi_record_log.rs
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ impl MultiRecordLog {
///
/// Returns an error if the queue already exists.
pub async fn create_queue(&mut self, queue: &str) -> Result<(), CreateQueueError> {
info!(queue=queue, "create queue");
info!(queue = queue, "create queue");
if self.queue_exists(queue) {
return Err(CreateQueueError::AlreadyExists);
}
Expand All @@ -171,7 +171,7 @@ impl MultiRecordLog {
}

pub async fn delete_queue(&mut self, queue: &str) -> Result<(), DeleteQueueError> {
info!(queue=queue, "delete queue");
info!(queue = queue, "delete queue");
let position = self.in_mem_queues.next_position(queue)?;
let record = MultiPlexedRecord::DeleteQueue { queue, position };
self.record_log_writer.write_record(record).await?;
Expand Down

0 comments on commit bc6a998

Please sign in to comment.