Skip to content

Commit 370bac2

Browse files
committed
Ignore file not found exception in delete_orphan_ack_files
If the dir is already deleted there's nothing to do
1 parent 89abb48 commit 370bac2

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/lavinmq/message_store.cr

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -557,6 +557,8 @@ module LavinMQ
557557
@replicator.try &.delete_file(path, WaitGroup.new)
558558
end
559559
end
560+
rescue File::NotFoundError
561+
# msg_dir does not exist, nothing to delete
560562
end
561563

562564
private def deleted?(seg, pos) : Bool

0 commit comments

Comments
 (0)