Module: RabbitJobs

Extended by:
RabbitJobs
Included in:
RabbitJobs
Defined in:
lib/rabbit_jobs.rb,
lib/rabbit_jobs/logger.rb,
lib/rabbit_jobs/worker.rb,
lib/rabbit_jobs/helpers.rb,
lib/rabbit_jobs/version.rb,
lib/rabbit_jobs/publisher.rb,
lib/rabbit_jobs/amqp_helpers.rb,
lib/rabbit_jobs/configuration.rb

Defined Under Namespace

Modules: AmqpHelpers, Helpers, Job, Logger, Publisher Classes: Configuration, Worker

Constant Summary collapse

VERSION = 
"0.0.4.1"

Instance Method Summary collapse

Instance Method Details

#config ⇒ Object 



13
14
15
 
# File 'lib/rabbit_jobs/configuration.rb', line 13

def config
  @@configuration ||= load_config
end

#configure(&block) ⇒ Object 



8
9
10
11
 
# File 'lib/rabbit_jobs/configuration.rb', line 8

def configure(&block)
  @@configuration ||= Configuration.new
  block.call(@@configuration)
end

#load_config ⇒ Object 



17
18
19
20
21
22
23
24
 
# File 'lib/rabbit_jobs/configuration.rb', line 17

def load_config
  self.configure do |c|
    c.host 'localhost'
    c.exchange 'rabbit_jobs', auto_delete: false, durable: true
    c.queue 'default', auto_delete: false, ack: true, durable: true
  end
  @@configuration
end

#publish(klass, opts = {}, *params) ⇒ Object 



17
18
19
 
# File 'lib/rabbit_jobs.rb', line 17

def publish(klass, opts = {}, *params)
  RabbitJobs::Publisher.publish(klass, opts, *params)
end

#publish_to(routing_key, klass, opts = {}, *params) ⇒ Object 



21
22
23
 
# File 'lib/rabbit_jobs.rb', line 21

def publish_to(routing_key, klass, opts = {}, *params)
  RabbitJobs::Publisher.publish_to(routing_key, klass, opts, *params)
end