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