Class: SolidQueueMonitor::QueuePauseService

Inherits:
Object
  • Object
show all
Defined in:
app/services/solid_queue_monitor/queue_pause_service.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(queue_name) ⇒ QueuePauseService

Returns a new instance of QueuePauseService.



7
8
9
10
 
# File 'app/services/solid_queue_monitor/queue_pause_service.rb', line 7

def initialize(queue_name)
  @queue_name = queue_name
  @queue = SolidQueue::Queue.new(queue_name)
end

Class Method Details

.paused_queues ⇒ Object 



30
31
32
 
# File 'app/services/solid_queue_monitor/queue_pause_service.rb', line 30

def self.paused_queues
  SolidQueue::Pause.pluck(:queue_name)
end

Instance Method Details

#pause ⇒ Object 



12
13
14
15
16
17
18
19
 
# File 'app/services/solid_queue_monitor/queue_pause_service.rb', line 12

def pause
  return { success: false, message: "Queue '#{@queue_name}' is already paused" } if paused?

  @queue.pause
  { success: true, message: "Queue '#{@queue_name}' has been paused" }
rescue StandardError => e
  { success: false, message: "Failed to pause queue: #{e.message}" }
end

#resume ⇒ Object 



21
22
23
24
25
26
27
28
 
# File 'app/services/solid_queue_monitor/queue_pause_service.rb', line 21

def resume
  return { success: false, message: "Queue '#{@queue_name}' is not paused" } unless paused?

  @queue.resume
  { success: true, message: "Queue '#{@queue_name}' has been resumed" }
rescue StandardError => e
  { success: false, message: "Failed to resume queue: #{e.message}" }
end