Skip to content

Commit f309b45

Browse files
dont continue startup if msg store is closed
1 parent 57c7710 commit f309b45

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
@@ -77,9 +77,10 @@ module LavinMQ::AMQP
7777
private def start
7878
if @msg_store.closed
7979
close
80+
else
81+
handle_arguments
82+
spawn unmap_and_remove_segments_loop, name: "Stream#unmap_and_remove_segments_loop"
8083
end
81-
handle_arguments
82-
spawn unmap_and_remove_segments_loop, name: "Stream#unmap_and_remove_segments_loop"
8384
end
8485

8586
private def init_msg_store(data_dir)

0 commit comments

Comments
 (0)