Merge pull request #115 from nownabe/bump_thread

Bump thread gem to 0.1.7

.travis.yml

@@ -1,6 +1,6 @@
 language: ruby
 rvm:
-- 2.2.0
-- 2.1.0
+- 2.2
+- 2.1
 - 2.0.0
 - 1.9.3

lib/sneakers/queue.rb

@@ -46,7 +46,7 @@ def subscribe(worker)
     # has the same configuration as the worker. Also pass along the exchange and
     # queue in case the handler requires access to them (for things like binding
     # retry queues, etc).
-    handler_klass = worker.opts[:handler] || Sneakers::CONFIG[:handler]
+    handler_klass = worker.opts[:handler] || Sneakers::CONFIG.fetch(:handler)
     handler = handler_klass.new(@channel, queue, worker.opts)
 
     @consumer = queue.subscribe(:block => false, :manual_ack => @opts[:ack]) do | delivery_info, metadata, msg |

sneakers.gemspec

@@ -18,7 +18,7 @@ Gem::Specification.new do |gem|
   gem.require_paths = ['lib']
   gem.add_dependency 'serverengine', '~> 1.5.5'
   gem.add_dependency 'bunny', '~> 1.7.0'
-  gem.add_dependency 'thread', '0.1.5'
+  gem.add_dependency 'thread', '~> 0.1.7'
   gem.add_dependency 'thor'
 
   gem.add_development_dependency 'rr'

spec/sneakers/queue_spec.rb

@@ -4,10 +4,6 @@
 
 
 describe Sneakers::Queue do
-  before do
-    Sneakers.configure
-  end
-
   let :queue_vars do
     {
       :prefetch => 25,
@@ -21,6 +17,8 @@
   end
 
   before do
+    Sneakers.configure
+
     @mkbunny = Object.new
     @mkchan = Object.new
     @mkex = Object.new