Skip to content

Commit 3e5c40a

Browse files
dont continue startup if msg store is closed
1 parent 6bb211c commit 3e5c40a

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

src/lavinmq/amqp/queue/queue.cr

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -197,10 +197,11 @@ module LavinMQ::AMQP
197197
private def start
198198
if @msg_store.closed
199199
close
200+
else
201+
handle_arguments
202+
spawn queue_expire_loop, name: "Queue#queue_expire_loop #{@vhost.name}/#{@name}" if @expires
203+
spawn message_expire_loop, name: "Queue#message_expire_loop #{@vhost.name}/#{@name}"
200204
end
201-
handle_arguments
202-
spawn queue_expire_loop, name: "Queue#queue_expire_loop #{@vhost.name}/#{@name}" if @expires
203-
spawn message_expire_loop, name: "Queue#message_expire_loop #{@vhost.name}/#{@name}"
204205
end
205206

206207
def restart!

src/lavinmq/amqp/stream/stream.cr

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,9 +76,10 @@ module LavinMQ::AMQP
7676
private def start
7777
if @msg_store.closed
7878
close
79+
else
80+
handle_arguments
81+
spawn unmap_and_remove_segments_loop, name: "Stream#unmap_and_remove_segments_loop"
7982
end
80-
handle_arguments
81-
spawn unmap_and_remove_segments_loop, name: "Stream#unmap_and_remove_segments_loop"
8283
end
8384

8485
private def init_msg_store(data_dir)

0 commit comments

Comments
 (0)