Fix how we call a symbol

healtronlabs · Feb 12, 2024 · e426ed3 · e426ed3
1 parent dbeff15
commit e426ed3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/gato/runner.cr b/src/gato/runner.cr
@@ -5,14 +5,14 @@ module Gato
 
       AMQP::Client.start(Gato.configuration.amqp_url.to_s) do |c|
         c.channel do |ch|
-          q = ch.queue arg0.queue_name
+          q = ch.queue arg0[:queue_name]
           ch.prefetch count: 1
 
           q.subscribe(no_ack: false, block: true) do |msg|
             message = JSON.parse msg.body_io.to_s
             Log.notice { "Received a new Message" }
 
-            arg0.block.call message
+            arg0[:block].call message
 
             Log.notice { "Done" }
           end