Class: ResqueBus::Rider

Inherits:
Object
  • Object
show all
Extended by:
Resque::Plugins::ExponentialBackoff
Defined in:
lib/resque_bus/compatibility/rider.rb

Class Method Summary collapse

Class Method Details

.on_failure_aaa(exception, *args) ⇒ Object 



19
20
21
22
23
 
# File 'lib/resque_bus/compatibility/rider.rb', line 19

def on_failure_aaa(exception, *args)
  # note: sorted alphabetically
  # queue needs to be set for rety to work (know what queue in Requeue.class_to_queue)
  @my_queue = args[0]["bus_rider_queue"]
end

.on_failure_zzz(exception, *args) ⇒ Object 



25
26
27
28
 
# File 'lib/resque_bus/compatibility/rider.rb', line 25

def on_failure_zzz(exception, *args)
  # note: sorted alphabetically
  @my_queue = nil
end

.perform(attributes = {}) ⇒ Object 



8
9
10
11
 
# File 'lib/resque_bus/compatibility/rider.rb', line 8

def perform(attributes = {})
  ResqueBus.note_deprecation "[MIGRATION] Note: new events will be using QueueBus::Rider"
  ::QueueBus::Rider.perform(attributes)
end

.queue ⇒ Object

to prevent running twice



15
16
17
 
# File 'lib/resque_bus/compatibility/rider.rb', line 15

def queue
  @my_queue
end