lib/splash/transports.rb in prometheus-splash-0.0.3 vs lib/splash/transports.rb in prometheus-splash-0.1.0

@@ -2,12 +2,12 @@
 
 module Splash
   module Transports
     include Splash::Config
 
-    def get_default_subscriber
-      aclass = "Splash::Transports::#{get_config[:transports][:active].to_s.capitalize}::Suscriber"
-      return Kernel.const_get(aclass)::new
+    def get_default_subscriber(queue)
+      aclass = "Splash::Transports::#{get_config[:transports][:active].to_s.capitalize}::Subscriber"
+      return Kernel.const_get(aclass)::new(queue)
     end
 
     def get_default_client
       aclass = "Splash::Transports::#{get_config[:transports][:active].to_s.capitalize}::Client"
       return Kernel.const_get(aclass)::new