Class: Totoro::BaseQueue

Inherits:
Object
  • Object
show all
Defined in:
lib/totoro/base_queue.rb

Class Method Summary collapse

Class Method Details

.channel ⇒ Object 



16
17
18
 
# File 'lib/totoro/base_queue.rb', line 16

def channel
  @channel ||= connection.create_channel
end

.config ⇒ Object 



8
9
10
 
# File 'lib/totoro/base_queue.rb', line 8

def config
  @config ||= Totoro::Config.new
end

.connection ⇒ Object 



12
13
14
 
# File 'lib/totoro/base_queue.rb', line 12

def connection
  @connection ||= Bunny.new(config.connect).tap(&:start)
end

.enqueue(id, payload) ⇒ Object

enqueue = publish to direct exchange



25
26
27
28
29
30
31
 
# File 'lib/totoro/base_queue.rb', line 25

def enqueue(id, payload)
  queue = channel.queue(*config.queue(id))
  payload = JSON.dump payload
  exchange.publish(payload, routing_key: queue.name)
  Rails.logger.info "send message to #{queue.name}"
  STDOUT.flush
end

.exchange ⇒ Object 



20
21
22
 
# File 'lib/totoro/base_queue.rb', line 20

def exchange
  @exchange ||= channel.default_exchange
end

.get_worker(worker_class) ⇒ Object 



40
41
42
 
# File 'lib/totoro/base_queue.rb', line 40

def get_worker(worker_class)
  ::Worker.const_get(worker_class.to_s.camelize).new
end

.subscribe(id) ⇒ Object 



33
34
35
36
37
38
 
# File 'lib/totoro/base_queue.rb', line 33

def subscribe(id)
  queue = channel.queue(*config.queue(id))
  queue.subscribe do |delivery_info, metadata, payload|
    yield(delivery_info, metadata, payload)
  end
end