Class: Cloudist::Publisher

Inherits:
Object show all
Defined in:
lib/cloudist/publisher.rb

Class Method Summary collapse

Class Method Details

.enqueue(queue_name, data) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/cloudist/publisher.rb', line 5

def enqueue(queue_name, data)
  payload = Cloudist::Payload.new(data)

  queue = Cloudist::JobQueue.new(queue_name)

  queue.setup

  # send_message = proc {
    queue.publish(payload)
  # }
  # EM.next_tick(&send_message)

  return Job.new(payload)
end