lib/async_observer/extend.rb in beanstalker-0.1.1 vs lib/async_observer/extend.rb in beanstalker-0.1.2

@@ -13,11 +13,11 @@
 # GNU General Public License for more details.
 
 # You should have received a copy of the GNU General Public License
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
-require 'async_observer/queue'
+require 'beanstalker/queue'
 
 CLASSES_TO_EXTEND = [
   ActiveRecord::Base,
   Array,
   Hash,
@@ -26,11 +26,11 @@
   Range,
   String,
   Symbol,
 ]
 
-module AsyncObserver::Extensions
+module Beanstalker::Extensions
   def self.included(receiver)
     @@methods_async_options = {}
     receiver.extend(ClassMethods)
   end
     
@@ -59,15 +59,15 @@
     async_send_opts(selector, @@methods_async_options[selector.to_sym] || {}, *args)
   end
 
   def async_send_opts(selector, opts, *args)
     interpolated_options = interpolate_async_options(opts, self)
-    AsyncObserver::Queue.put_call!(self, selector, interpolated_options, args)
+    Beanstalker::Queue.put_call!(self, selector, interpolated_options, args)
   end
 end
 
 CLASSES_TO_EXTEND.each do |c|
-  c.send :include, AsyncObserver::Extensions
+  c.send :include, Beanstalker::Extensions
 end
 
 class Range
   DEFAULT_FANOUT_FUZZ = 0
   DEFAULT_FANOUT_DEGREE = 1000