vendor minion gem and amqp dependencies

config/environment.rb

@@ -5,4 +5,7 @@
 Rails::Initializer.run do |config|
   config.time_zone = 'UTC'
   config.gem 'feedtools', :lib => 'feed_tools'
+  config.gem 'tmm1-amqp', :lib => 'mq', :source => 'http://gems.github.com'
+  config.gem 'bunny'
+  config.gem 'minion'
 end

vendor/gems/bunny-0.5.3/.specification

@@ -0,0 +1,100 @@
+--- !ruby/object:Gem::Specification 
+name: bunny
+version: !ruby/object:Gem::Version 
+  version: 0.5.3
+platform: ruby
+authors: 
+- Chris Duncan
+autorequire: 
+bindir: bin
+cert_chain: []
+
+date: 2009-09-06 00:00:00 -07:00
+default_executable: 
+dependencies: []
+
+description: Another synchronous Ruby AMQP client
+email: celldee@gmail.com
+executables: []
+
+extensions: []
+
+extra_rdoc_files: 
+- README
+files: 
+- LICENSE
+- README
+- Rakefile
+- bunny.gemspec
+- examples/simple_08.rb
+- examples/simple_ack_08.rb
+- examples/simple_consumer_08.rb
+- examples/simple_fanout_08.rb
+- examples/simple_publisher_08.rb
+- examples/simple_topic_08.rb
+- examples/simple_headers_08.rb
+- examples/simple_09.rb
+- examples/simple_ack_09.rb
+- examples/simple_consumer_09.rb
+- examples/simple_fanout_09.rb
+- examples/simple_publisher_09.rb
+- examples/simple_topic_09.rb
+- examples/simple_headers_09.rb
+- lib/bunny.rb
+- lib/bunny/channel08.rb
+- lib/bunny/channel09.rb
+- lib/bunny/client08.rb
+- lib/bunny/client09.rb
+- lib/bunny/exchange08.rb
+- lib/bunny/exchange09.rb
+- lib/bunny/queue08.rb
+- lib/bunny/queue09.rb
+- lib/qrack/client.rb
+- lib/qrack/channel.rb
+- lib/qrack/queue.rb
+- lib/qrack/protocol/protocol08.rb
+- lib/qrack/protocol/protocol09.rb
+- lib/qrack/protocol/spec08.rb
+- lib/qrack/protocol/spec09.rb
+- lib/qrack/qrack08.rb
+- lib/qrack/qrack09.rb
+- lib/qrack/transport/buffer08.rb
+- lib/qrack/transport/buffer09.rb
+- lib/qrack/transport/frame08.rb
+- lib/qrack/transport/frame09.rb
+- spec/spec_08/bunny_spec.rb
+- spec/spec_08/exchange_spec.rb
+- spec/spec_08/queue_spec.rb
+- spec/spec_09/bunny_spec.rb
+- spec/spec_09/exchange_spec.rb
+- spec/spec_09/queue_spec.rb
+has_rdoc: true
+homepage: http://github.com/celldee/bunny/tree/master
+post_install_message: 
+rdoc_options: 
+- --main
+- README
+require_paths: 
+- bin
+- lib
+required_ruby_version: !ruby/object:Gem::Requirement 
+  requirements: 
+  - - ">="
+    - !ruby/object:Gem::Version 
+      version: "0"
+  version: 
+required_rubygems_version: !ruby/object:Gem::Requirement 
+  requirements: 
+  - - ">="
+    - !ruby/object:Gem::Version 
+      version: "0"
+  version: 
+requirements: []
+
+rubyforge_project: bunny-amqp
+rubygems_version: 1.3.1
+signing_key: 
+specification_version: 3
+summary: A synchronous Ruby AMQP client that enables interaction with AMQP-compliant brokers/servers.
+test_files: []
+

vendor/gems/bunny-0.5.3/LICENSE

@@ -0,0 +1,20 @@
+Copyright (c) 2009 Chris Duncan
+
+Permission is hereby granted, free of charge, to any person obtaining
+a copy of this software and associated documentation files (the
+"Software"), to deal in the Software without restriction, including
+without limitation the rights to use, copy, modify, merge, publish,
+distribute, sublicense, and/or sell copies of the Software, and to
+permit persons to whom the Software is furnished to do so, subject to
+the following conditions:
+
+The above copyright notice and this permission notice shall be
+included in all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

vendor/gems/bunny-0.5.3/README

@@ -0,0 +1,59 @@
+= Bunny: A synchronous Ruby AMQP client
+
+*GitHub* *repo*: http://github.com/celldee/bunny
+*Rubyforge*: http://rubyforge.org/projects/bunny-amqp
+*Twitter*: http://twitter.com/bunny_amqp
+*Google* *Group*: http://groups.google.com/group/bunny-amqp
+
+=== DESCRIPTION:
+
+Bunny is an AMQP[http://www.amqp.org] (Advanced Message Queuing Protocol) client, written in Ruby, that is intended to allow you to interact with AMQP-compliant message brokers/servers such as RabbitMQ[http://www.rabbitmq.com] in a synchronous fashion.
+
+It is based on a great deal of useful code from amqp[http://github.com/tmm1/amqp] by Aman Gupta and Carrot[http://github.com/famoseagle/carrot] by Amos Elliston.
+
+You can use Bunny to -
+
+* Create and delete exchanges
+* Create and delete queues
+* Publish and consume messages
+
+Bunny is known to work with RabbitMQ versions 1.5.4, 1.5.5, 1.6.0 and version 0-8 of the AMQP specification.
+
+=== INSTALL:
+
+*Rubyforge*: <tt>gem install bunny</tt>
+
+*GitHub*: <tt>gem install celldee-bunny</tt>
+
+=== QUICK START:
+
+   require 'bunny'
+
+   b = Bunny.new(:logging => true)
+
+   # start a communication session with the amqp server
+   b.start
+
+   # declare a queue
+   q = b.queue('test1')
+
+   # publish a message to the queue
+   q.publish('Hello everybody!')
+
+   # get message from the queue
+   msg = q.pop
+
+   puts 'This is the message: ' + msg + "\n\n"
+
+   # close the connection
+   b.stop
+
+=== EVEN QUICKER START
+
+   require 'bunny'
+
+   # Create a direct queue named 'my_testq'
+   Bunny.run { |c| c.queue('my_testq') }
+
+=== OTHER:
+Please see the _examples_ directory for additional usage information.

vendor/gems/bunny-0.5.3/Rakefile

@@ -0,0 +1,24 @@
+desc "Run AMQP 0-8 rspec tests"
+task :spec08 do
+	require 'spec/rake/spectask'
+	puts "===== Running 0-8 tests ====="
+	Spec::Rake::SpecTask.new("spec08") do |t|
+		t.spec_files = FileList["spec/spec_08/*_spec.rb"]
+		t.spec_opts = ['--color']
+	end
+end
+
+desc "Run AMQP 0-9 rspec tests"
+task :spec09 do
+	require 'spec/rake/spectask'
+	puts "===== Running 0-9 tests ====="
+	Spec::Rake::SpecTask.new("spec09") do |t|
+		t.spec_files = FileList["spec/spec_09/*_spec.rb"]
+		t.spec_opts = ['--color']
+	end
+end
+
+task :default => [ :spec08 ]
+
+desc "Run all rspec tests"
+task :all => [:spec08, :spec09]

vendor/gems/bunny-0.5.3/bunny.gemspec

@@ -0,0 +1,60 @@
+Gem::Specification.new do |s|
+  s.name = %q{bunny}
+  s.version = "0.5.3"
+  s.authors = ["Chris Duncan"]
+  s.date = %q{2009-09-07}
+  s.description = %q{Another synchronous Ruby AMQP client}
+  s.email = %q{celldee@gmail.com}
+  s.rubyforge_project = %q{bunny-amqp}
+  s.has_rdoc = true
+ 	s.extra_rdoc_files = [ "README" ]
+  s.rdoc_options = [ "--main", "README" ]
+  s.homepage = %q{http://github.com/celldee/bunny/tree/master}
+  s.summary = %q{A synchronous Ruby AMQP client that enables interaction with AMQP-compliant brokers/servers.}
+  s.files = ["LICENSE",
+	 	"README",
+		"Rakefile",
+		"bunny.gemspec",
+		"examples/simple_08.rb",
+		"examples/simple_ack_08.rb",
+		"examples/simple_consumer_08.rb",
+		"examples/simple_fanout_08.rb",
+		"examples/simple_publisher_08.rb",
+		"examples/simple_topic_08.rb",
+		"examples/simple_headers_08.rb",
+		"examples/simple_09.rb",
+		"examples/simple_ack_09.rb",
+		"examples/simple_consumer_09.rb",
+		"examples/simple_fanout_09.rb",
+		"examples/simple_publisher_09.rb",
+		"examples/simple_topic_09.rb",
+		"examples/simple_headers_09.rb",
+		"lib/bunny.rb",
+		"lib/bunny/channel08.rb",
+		"lib/bunny/channel09.rb",
+		"lib/bunny/client08.rb",
+		"lib/bunny/client09.rb",
+		"lib/bunny/exchange08.rb",
+		"lib/bunny/exchange09.rb",
+		"lib/bunny/queue08.rb",
+		"lib/bunny/queue09.rb",
+		"lib/qrack/client.rb",
+		"lib/qrack/channel.rb",
+		"lib/qrack/queue.rb",
+		"lib/qrack/protocol/protocol08.rb",
+		"lib/qrack/protocol/protocol09.rb",
+		"lib/qrack/protocol/spec08.rb",
+		"lib/qrack/protocol/spec09.rb",
+		"lib/qrack/qrack08.rb",
+		"lib/qrack/qrack09.rb",
+		"lib/qrack/transport/buffer08.rb",
+		"lib/qrack/transport/buffer09.rb",
+		"lib/qrack/transport/frame08.rb",
+		"lib/qrack/transport/frame09.rb",
+		"spec/spec_08/bunny_spec.rb",
+		"spec/spec_08/exchange_spec.rb",
+		"spec/spec_08/queue_spec.rb",
+		"spec/spec_09/bunny_spec.rb",
+		"spec/spec_09/exchange_spec.rb",
+		"spec/spec_09/queue_spec.rb"]
+end

vendor/gems/bunny-0.5.3/examples/simple_08.rb

@@ -0,0 +1,30 @@
+# simple_08.rb
+
+# Assumes that target message broker/server has a user called 'guest' with a password 'guest'
+# and that it is running on 'localhost'.
+
+# If this is not the case, please change the 'Bunny.new' call below to include
+# the relevant arguments e.g. b = Bunny.new(:user => 'john', :pass => 'doe', :host => 'foobar')
+
+$:.unshift File.dirname(__FILE__) + '/../lib'
+
+require 'bunny'
+
+b = Bunny.new(:logging => true)
+
+# start a communication session with the amqp server
+b.start
+
+# declare a queue
+q = b.queue('test1')
+
+# publish a message to the queue
+q.publish('Hello everybody!')
+
+# get message from the queue
+msg = q.pop
+
+puts 'This is the message: ' + msg + "\n\n"
+
+# close the client connection
+b.stop

vendor/gems/bunny-0.5.3/examples/simple_09.rb

@@ -0,0 +1,30 @@
+# simple_09.rb
+
+# Assumes that target message broker/server has a user called 'guest' with a password 'guest'
+# and that it is running on 'localhost'.
+
+# If this is not the case, please change the 'Bunny.new' call below to include
+# the relevant arguments e.g. b = Bunny.new(:user => 'john', :pass => 'doe', :host => 'foobar')
+
+$:.unshift File.dirname(__FILE__) + '/../lib'
+
+require 'bunny'
+
+b = Bunny.new(:logging => true, :spec => '09')
+
+# start a communication session with the amqp server
+b.start
+
+# declare a queue
+q = b.queue('test1')
+
+# publish a message to the queue
+q.publish('Hello everybody!')
+
+# get message from the queue
+msg = q.pop
+
+puts 'This is the message: ' + msg + "\n\n"
+
+# close the client connection
+b.stop

vendor/gems/bunny-0.5.3/examples/simple_ack_08.rb

@@ -0,0 +1,33 @@
+# simple_ack_08.rb
+
+# Assumes that target message broker/server has a user called 'guest' with a password 'guest'
+# and that it is running on 'localhost'.
+
+# If this is not the case, please change the 'Bunny.new' call below to include
+# the relevant arguments e.g. b = Bunny.new(:user => 'john', :pass => 'doe', :host => 'foobar')
+
+$:.unshift File.dirname(__FILE__) + '/../lib'
+
+require 'bunny'
+
+b = Bunny.new(:logging => true)
+
+# start a communication session with the amqp server
+b.start
+
+# declare a queue
+q = b.queue('test1')
+
+# publish a message to the queue
+q.publish('Testing acknowledgements')
+
+# get message from the queue
+msg = q.pop(:ack => true)
+
+# acknowledge receipt of message
+q.ack
+
+puts 'This is the message: ' + msg + "\n\n"
+
+# close the client connection
+b.stop