Contents

require 'untied-consumer/worker'
require 'amqp'

namespace :untied do
  namespace :consumer do
    desc "Starts untied's worker"
    task :work => :environment do
      AMQP.start do |connection|
        channel  = AMQP::Channel.new(connection)
        exchange = channel.topic("untied", :auto_delete => true)
        worker = Untied::Consumer::Worker.new(:channel => channel, :exchange => exchange)
        worker.start
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
untied-consumer-0.0.3	lib/untied-consumer/tasks/untied_rails.tasks
untied-consumer-0.0.2	lib/untied-consumer/tasks/untied_rails.tasks
untied-consumer-0.0.1	lib/untied-consumer/tasks/untied_rails.tasks