class RabbitJobs::Publisher::Base
Abstract publisher.
Public Class Methods
cleanup()
click to toggle source
# File lib/rabbit_jobs/publisher/base.rb, line 6 def cleanup fail NotImplementedError end
direct_publish_to(_routing_key, _payload, _ex = {})
click to toggle source
# File lib/rabbit_jobs/publisher/base.rb, line 14 def direct_publish_to(_routing_key, _payload, _ex = {}) fail NotImplementedError end
publish_to(_routing_key, _klass, *_params)
click to toggle source
# File lib/rabbit_jobs/publisher/base.rb, line 10 def publish_to(_routing_key, _klass, *_params) fail NotImplementedError end
purge_queue(*_routing_keys)
click to toggle source
# File lib/rabbit_jobs/publisher/base.rb, line 18 def purge_queue(*_routing_keys) fail NotImplementedError end
queue_status(_routing_key)
click to toggle source
# File lib/rabbit_jobs/publisher/base.rb, line 22 def queue_status(_routing_key) fail NotImplementedError end
Protected Class Methods
check_amqp_publishing_params(routing_key, klass)
click to toggle source
# File lib/rabbit_jobs/publisher/base.rb, line 28 def check_amqp_publishing_params(routing_key, klass) fail ArgumentError, "klass=#{klass.inspect}" unless klass.is_a?(Class) || klass.is_a?(String) routing_key = routing_key.to_sym unless routing_key.is_a?(Symbol) fail ArgumentError, "routing_key=#{routing_key}" unless RabbitJobs.config[:queues][routing_key] end
check_queue_status_params(routing_key)
click to toggle source
# File lib/rabbit_jobs/publisher/base.rb, line 34 def check_queue_status_params(routing_key) fail ArgumentError, 'routing_key is blank' if routing_key.blank? fail ArgumentError, "Unknown queue: #{routing_key}" unless RJ.config.queue?(routing_key) end