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