Module: Que::Utils::QueueManagement

Included in:
Que
Defined in:
lib/que/utils/queue_management.rb

Instance Method Summary collapse

Instance Method Details

#clear! ⇒ Object 



8
9
10
 
# File 'lib/que/utils/queue_management.rb', line 8

def clear!
  execute "DELETE FROM que_jobs"
end

#create! ⇒ Object

Very old migrations may use Que.create! and Que.drop!, which just created and dropped the initial version of the jobs table.



14
 
# File 'lib/que/utils/queue_management.rb', line 14

def create!; migrate!(version: 1); end

#drop! ⇒ Object 



15
 
# File 'lib/que/utils/queue_management.rb', line 15

def drop!;   migrate!(version: 0); end