Sha256: 9fa152a1665e0c8cf6555673bc4ba43d0b9f06a7dee53de58fbd1985dea25a25
Contents?: true
Size: 909 Bytes
Versions: 17
Compression:
Stored size: 909 Bytes
Contents
require 'active_support/core_ext/string/inflections'
require 'resque'
module Pwwka
# 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 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"
#
# 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 QueueResqueJobHandler
def self.handle!(delivery_info,properties,payload)
Resque.enqueue(ENV["JOB_KLASS"].constantize, payload)
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems