lib/splash/transports.rb in prometheus-splash-0.5.3 vs lib/splash/transports.rb in prometheus-splash-0.6.0

- old
+ new

@@ -1,11 +1,18 @@ # coding: utf-8 +# base Splash module module Splash + + # Splash Transports namespace module Transports include Splash::Config + + # factory for Splash::Transports::Rabbitmq::Subscriber + # @param [Hash] options + # @return [Splash::Transports::Rabbitmq::Subscriber|Hash] Subscriber or Exiter case :configuration_error def get_default_subscriber(options) config = get_config.transports transport = config[:active] host = config[transport][:host] port = config[transport][:port] @@ -18,9 +25,11 @@ rescue return { :case => :configuration_error, :more => "Transport specified for queue #{options[:queue]} configuration error : #{transport}"} end end + # factory for Splash::Transports::Rabbitmq::Client + # @return [Splash::Transports::Rabbitmq::Client|Hash] Client or Exiter case :configuration_error def get_default_client config = get_config.transports transport = config[:active] host = config[transport][:host] port = config[transport][:port]