lib/cloudist/publisher.rb in cloudist-0.4.4 vs lib/cloudist/publisher.rb in cloudist-0.5.0

- old
+ new

@@ -1,22 +1,22 @@ module Cloudist class Publisher - + class << self 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 end - + end end