diff --git a/lib/resque_spec/scheduler.rb b/lib/resque_spec/scheduler.rb
index d7af460..c385247 100644
--- a/lib/resque_spec/scheduler.rb
+++ b/lib/resque_spec/scheduler.rb
@@ -84,7 +84,7 @@ def is_time?(time)
   end
 
   def schedule_queue_name(klass)
-    "#{queue_name(klass)}_scheduled"
+    queue_name(klass)
   end
 end
 
diff --git a/spec/resque_spec/scheduler_spec.rb b/spec/resque_spec/scheduler_spec.rb
index c9fe7d0..e38ab24 100644
--- a/spec/resque_spec/scheduler_spec.rb
+++ b/spec/resque_spec/scheduler_spec.rb
@@ -157,6 +157,11 @@
       it "uses the correct queue" do
         ResqueSpec.queue_by_name(:test_queue).should_not be_empty
       end
+
+      it "uses the correct queue when the queue argument is the same defined on the worker class" do
+        Resque.enqueue_in_with_queue(:name_from_class_method, scheduled_in, NameFromClassMethod, 1)
+        ResqueSpec.schedule_for(NameFromClassMethod).should_not be_empty
+      end
     end
 
     describe "#remove_delayed" do