Contents

#!/usr/bin/env ruby

require "amqp"

require "untied"
require "untied/worker"

module Untied
  AMQP.start do |connection|
    channel  = AMQP::Channel.new(connection)
    exchange = channel.topic("untied", :auto_delete => true)
    # consumer = Consumer.new
    worker = Consumer::Worker.new(:channel => channel, :exchange => exchange)
    worker.start
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
untied-0.0.7.pre3	bin/untied_worker
untied-0.0.5	bin/untied_worker
untied-0.0.4	bin/untied_worker
untied-0.0.1	bin/untied_worker