From bc6a998966603e11928ff23914d6da169fc8fce6 Mon Sep 17 00:00:00 2001 From: Paul Masurel Date: Tue, 27 Feb 2024 13:45:29 +0900 Subject: [PATCH] Fix format --- src/multi_record_log.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/multi_record_log.rs b/src/multi_record_log.rs index f9e871e..68d1bc7 100644 --- a/src/multi_record_log.rs +++ b/src/multi_record_log.rs @@ -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); } @@ -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?;