lib/rising_dragon/sqs/worker.rb in rising_dragon-0.3.2 vs lib/rising_dragon/sqs/worker.rb in rising_dragon-0.3.3

@@ -8,20 +8,20 @@
         base.extend(ClassMethods)
       end
 
       module ClassMethods
         def rising_dragon_options(sqs_queue_name, opt = {})
-          shoryuken_opt = { queue: sqs_queue_name, body_parser: :json, auto_delete: true, shoryuken_group: "default_group" }.merge(opt)
+          shoryuken_opt = { queue: sqs_queue_name, body_parser: :json, auto_delete: true, shoryuken_group: "default" }.merge(opt)
           shoryuken_options(shoryuken_opt)
 
-          register_queue(sqs_queue_name, shoryuken_opt[:shoryuken_group], opt)
+          register_queue(sqs_queue_name, shoryuken_opt["shoryuken_group"], opt) # shoryuken_options will change hash key.... :(
         end
 
         def register_queue(sqs_queue_name, group_name, option)
-          concurrency = option[:concurrency] || 25
+          concurrency = option["concurrency"] || 25
           Shoryuken.add_group(group_name, concurrency)
 
-          weight = option[:weight] || 1
+          weight = option["weight"] || 1
           Shoryuken.add_queue(sqs_queue_name, weight, group_name)
         end
 
         def rising_dragon_register(event_name, handle_class)
           emitter.register(event_name, handle_class)