Class: Pwwka::QueueResqueJobHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/pwwka/queue_resque_job_handler.rb

Overview

A handler that simply queues the payload into a Resque job. This is useful if the code that should respond to a message needs to be managed by Resque, e.g. for the purposes of retry or better failure management. You can ask for the routing key and properties by setting ‘PWWKA_QUEUE_EXTENDED_INFO` to `true` in your environment.

You should be able to use this directly from your handler configuration, e.g. for a Heroku-style ‘Procfile`:

my_handler: rake message_handler:receive HANDLER_KLASS=Pwwka::QueueResqueJobHandler JOB_KLASS=MyResqueJob QUEUE_NAME=my_queue ROUTING_KEY="my.key.completed"
my_handler_that_wants_more_info: rake message_handler:receive HANDLER_KLASS=Pwwka::QueueResqueJobHandler JOB_KLASS=MyOthgerResqueJob PWWKA_QUEUE_EXTENDED_INFO=true QUEUE_NAME=my_queue ROUTING_KEY="my.key.#"

Note that this will not check the routing key, so you should be sure to specify the most precise ROUTING_KEY you can for handling the message.

Class Method Summary collapse

Class Method Details

.handle!(delivery_info, properties, payload) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/pwwka/queue_resque_job_handler.rb', line 17

def self.handle!(delivery_info,properties,payload)
  job_klass = ENV["JOB_KLASS"].constantize
  args = [
    job_klass,
    payload
  ]
  if ENV["PWWKA_QUEUE_EXTENDED_INFO"] == 'true' || job_klass_can_handle_args?(job_klass)
    args << delivery_info.routing_key
    args << properties.to_hash
  end
  Resque.enqueue(*args)
end