lib/rosetta_queue.rb in cwyckoff-rosetta_queue-0.2.2 vs lib/rosetta_queue.rb in cwyckoff-rosetta_queue-0.3.0

@@ -9,9 +9,11 @@
 require 'rosetta_queue/exceptions'
 require 'rosetta_queue/filters'
 require 'rosetta_queue/logger'
 require 'rosetta_queue/message_handler'
 require 'rosetta_queue/producer'
+require 'rosetta_queue/consumer_managers/base'
+require 'rosetta_queue/consumer_managers/threaded'
 
 if defined?(Rails)
   RosettaQueue.logger = RosettaQueue::Logger.new(File.join(Rails.root, 'log', 'rosetta_queue.log'))
   require('rosetta_queue/spec_helpers') if Rails.env == "test"
 end