Class: QueueClassicAdmin::QueueClassicJobsController

Inherits:
ApplicationController show all
Defined in:
app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb

Instance Method Summary collapse

Instance Method Details

#custom ⇒ Object 



37
38
39
40
41
 
# File 'app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb', line 37

def custom
  custom_action = QueueClassicAdmin.custom_actions[params[:custom_action]]
  custom_action.action.call(@queue_classic_job)
  redirect_to :back
end

#destroy ⇒ Object 



11
12
13
14
 
# File 'app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb', line 11

def destroy
  @queue_classic_job.destroy
  redirect_to :back
end

#destroy_all ⇒ Object 



16
17
18
19
 
# File 'app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb', line 16

def destroy_all
  filter_jobs(QueueClassicJob).delete_all
  redirect_to queue_classic_jobs_url
end

#index ⇒ Object 



6
7
8
9
 
# File 'app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb', line 6

def index
  filter_jobs(QueueClassicJob)
  @queue_classic_jobs = @queue_classic_jobs.paginate(page: params[:page])
end

#show ⇒ Object 



32
33
34
35
 
# File 'app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb', line 32

def show
  query = "SELECT * FROM pg_catalog.pg_locks lock JOIN pg_catalog.pg_stat_activity stat ON lock.pid = stat.pid WHERE lock.pid = #{@queue_classic_job.locked_by.to_i}"
  @locks = QueueClassicJob.connection.execute(query)
end

#unlock ⇒ Object 



26
27
28
29
30
 
# File 'app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb', line 26

def unlock
  @queue_classic_job.locked_at = nil
  @queue_classic_job.save
  redirect_to :back
end

#unlock_all ⇒ Object 



21
22
23
24
 
# File 'app/controllers/queue_classic_admin/queue_classic_jobs_controller.rb', line 21

def unlock_all
  filter_jobs(QueueClassicJob).where('locked_at < ?', 5.minutes.ago).update_all(locked_at: nil)
  redirect_to queue_classic_jobs_url
end