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