Sha256: ceb0c0cd66589150271123296d8dac24f3494a5b2f74257184f24358e254ebb5
Contents?: true
Size: 573 Bytes
Versions: 30
Compression:
Stored size: 573 Bytes
Contents
namespace :message_handler do
desc "Start the message bus receiver"
task :receive => :environment do
raise "HANDLER_KLASS must be set" unless ENV['HANDLER_KLASS']
raise "QUEUE_NAME must be set" unless ENV['QUEUE_NAME']
handler_klass = ENV['HANDLER_KLASS'].constantize
queue_name = "#{ENV['QUEUE_NAME']}_#{Rails.env}"
routing_key = ENV['ROUTING_KEY'] || "#.#"
prefetch = ENV['PREFETCH'] || Pwwka.configuration.default_prefetch
Pwwka::Receiver.subscribe(handler_klass, queue_name, routing_key: routing_key, prefetch: prefetch)
end
end
Version data entries
30 entries across 30 versions & 1 rubygems