lib/rosetta_queue/adapters/beanstalk.rb in bmabey-rosetta_queue-0.1.3 vs lib/rosetta_queue/adapters/beanstalk.rb in bmabey-rosetta_queue-0.2.0

@@ -7,12 +7,12 @@
 
       def ack(msg)
         @conn.ack(msg.headers["message-id"])
       end
 
-      def initialize(user=nil, password=nil, host="localhost", port=11300)
-        @host, @port = host, port
-        @conn = Beanstalk::Pool.new(["#{host}:#{port}"])
+      def initialize(adapter_settings = {})
+        @host, @port = adapter_settings[:host], adapter_settings[:port]
+        @conn = Beanstalk::Pool.new(["#{@host}:#{@port}"])
       end
 
       def disconnect; end
 
       # TODO: support options[:timeout] ?