Skip to content

Commit

Permalink
Add durable
Browse files Browse the repository at this point in the history
  • Loading branch information
descholar-ceo committed Feb 12, 2024
1 parent 6d57f95 commit 2a51b64
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/gato/runner.cr
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ module Gato
q = ch.queue curr_param[:queue_name], durable: true
ch.prefetch count: 1

q.subscribe(no_ack: false, block: true) do |msg|
q.subscribe(no_ack: false, block: false) do |msg|
message = JSON.parse msg.body_io.to_s
Log.notice { "Received a new message for #{curr_param[:queue_name]} queue" }
curr_param[:message_handler].call message
Expand Down

0 comments on commit 2a51b64

Please sign in to comment.