lib/rosetta_queue/adapter.rb in cwyckoff-rosetta_queue-0.1.4 vs lib/rosetta_queue/adapter.rb in cwyckoff-rosetta_queue-0.2.0

@@ -13,9 +13,10 @@
       def reset
         @user, @password, @host, @port, @options, @adapter_class = nil, nil, nil, nil, nil, nil
       end
       
       def type=(adapter_prefix)
+        require "rosetta_queue/adapters/amqp_base" if adapter_prefix =~ /amqp/
         require "rosetta_queue/adapters/#{adapter_prefix}"
         @adapter_class = RosettaQueue::Gateway.const_get("#{adapter_prefix.to_s.classify}Adapter")
 
         rescue MissingSourceFile
           raise AdapterException, "Adapter type '#{adapter_prefix}' does not match existing adapters!"