Class: RabbitJobs::Publisher::Sync

Inherits:
Base
  • Object
show all
Defined in:
lib/rabbit_jobs/publisher/sync.rb

Class Method Summary collapse

Methods inherited from Base

direct_publish_to

Class Method Details

.cleanup ⇒ Object 



8
9
 
# File 'lib/rabbit_jobs/publisher/sync.rb', line 8

def cleanup
end

.publish_to(routing_key, klass, *params) ⇒ Object

Raises:

  • (ArgumentError) 


11
12
13
14
15
16
17
 
# File 'lib/rabbit_jobs/publisher/sync.rb', line 11

def publish_to(routing_key, klass, *params)
  raise ArgumentError.new("klass=#{klass.inspect}") unless klass.is_a?(Class) || klass.is_a?(String)
  routing_key = routing_key.to_sym unless routing_key.is_a?(Symbol)
  raise ArgumentError.new("routing_key=#{routing_key}") unless RabbitJobs.config[:queues][routing_key]

  klass.perform(*params)
end

.purge_queue(*routing_keys) ⇒ Object 



19
20
 
# File 'lib/rabbit_jobs/publisher/sync.rb', line 19

def purge_queue(*routing_keys)
end