Contents

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

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
cloudist-0.4.4	lib/cloudist/publisher.rb
cloudist-0.4.3	lib/cloudist/publisher.rb
cloudist-0.4.2	lib/cloudist/publisher.rb
cloudist-0.4.1	lib/cloudist/publisher.rb