Merge pull request #30 from slavaZim/fix-add-mechanisms

add auth_mechanisms in options
pma · Oct 20, 2016 · 22f0eff · 22f0eff
2 parents 763dbf3 + 99046d8
commit 22f0eff
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/amqp/connection.ex b/lib/amqp/connection.ex
@@ -86,7 +86,8 @@ defmodule AMQP.Connection do
                           connection_timeout: Keyword.get(options, :connection_timeout, :infinity),
                           ssl_options:        Keyword.get(options, :ssl_options,        :none),
                           client_properties:  Keyword.get(options, :client_properties,  []),
-                          socket_options:     Keyword.get(options, :socket_options,     []))
+                          socket_options:     Keyword.get(options, :socket_options,     []),
+                          auth_mechanisms:    Keyword.get(options, :auth_mechanisms,    [&:amqp_auth_mechanisms.plain/3, &:amqp_auth_mechanisms.amqplain/3]))
 
     do_open(amqp_params)
   end