lib/sidekiq/cron/job.rb in sidekiq-cron-0.3.0 vs lib/sidekiq/cron/job.rb in sidekiq-cron-0.3.1

@@ -215,9 +215,11 @@
         #get right arguments for job
         @args = args["args"].nil? ? [] : parse_args( args["args"] )
 
         if args["message"]
           @message = args["message"]
+          message_data = Sidekiq.load_json(@message) || {}
+          @queue = message_data['queue'] || default
         elsif @klass
           message_data = {
             "class" => @klass.to_s,
             "args"  => @args,
           }