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]