lib/cloudist/publisher.rb in cloudist-0.2.1 vs lib/cloudist/publisher.rb in cloudist-0.4.1

@@ -2,13 +2,18 @@
   class Publisher
     
     class << self
       def enqueue(queue_name, data)
         payload = Cloudist::Payload.new(data)
-
+        
         queue = Cloudist::JobQueue.new(queue_name)
+        
         queue.setup
-        queue.publish(payload)
+        
+        # send_message = proc {
+          queue.publish(payload)
+        # }
+        # EM.next_tick(&send_message)
         
         return Job.new(payload)
       end
     end