lib/rosetta_queue/adapter.rb in bmabey-rosetta_queue-0.2.0 vs lib/rosetta_queue/adapter.rb in bmabey-rosetta_queue-0.3.3
- old
+ new
@@ -3,19 +3,19 @@
module RosettaQueue
class Adapter
class << self
attr_writer :user, :password, :host, :port, :options
-
+
def define
yield self
end
-
+
def reset
@user, @password, @host, @port, @options, @adapter_class = nil, nil, nil, nil, nil, nil
end
-
+
def type=(adapter_prefix)
require "rosetta_queue/adapters/#{adapter_prefix}"
@adapter_class = RosettaQueue::Gateway.const_get("#{adapter_prefix.to_s.classify}Adapter")
rescue LoadError
@@ -26,14 +26,14 @@
raise AdapterException, "Adapter type was never defined!" unless @adapter_class
@adapter_class.new({:user => @user, :password => @password, :host => @host, :port => @port, :opts => opts})
end
private
-
+
def opts
raise AdapterException, "Adapter options should be a hash" unless @options.nil? || @options.is_a?(Hash)
@options ||= {}
end
-
+
end
- end
+ end
end