1 files changed, 13 insertions, 11 deletions
diff --git a/activejob/test/support/integration/adapters/que.rb b/activejob/test/support/integration/adapters/que.rb
index ba7657a42a..ff5235bdc8 100644
--- a/activejob/test/support/integration/adapters/que.rb
+++ b/activejob/test/support/integration/adapters/que.rb
@@ -2,6 +2,15 @@ module QueJobsManager
   def setup
     require 'sequel'
     ActiveJob::Base.queue_adapter = :que
+    Que.mode = :off
+    Que.worker_count = 1
+  end
+
+  def clear_jobs
+    Que.clear!
+  end
+
+  def start_workers
     que_url = ENV['QUE_DATABASE_URL'] || 'postgres:///active_jobs_que_int_test'
     uri = URI.parse(que_url)
     user = uri.user||ENV['USER']
@@ -11,24 +20,17 @@ module QueJobsManager
     %x{#{"PGPASSWORD=\"#{pass}\"" if pass} psql -c 'create database "#{db}"' -U #{user} -t template1}
     Que.connection = Sequel.connect(que_url)
     Que.migrate!
-    Que.mode = :off
-    Que.worker_count = 1
-  rescue Sequel::DatabaseConnectionError
-    puts "Cannot run integration tests for que. To be able to run integration tests for que you need to install and start postgresql.\n"
-    exit
-  end
-
-  def clear_jobs
-    Que.clear!
-  end
 
-  def start_workers
     @thread = Thread.new do
       loop do
         Que::Job.work("integration_tests")
         sleep 0.5
       end
     end
+
+  rescue Sequel::DatabaseConnectionError
+    puts "Cannot run integration tests for que. To be able to run integration tests for que you need to install and start postgresql.\n"
+    exit
   end
 
   def stop_workers