Merge pull request #1 from Gsantomaggio/rabbitmq-vshovel-dependency

Add rabbitmq dependency
cloudamqp · Jun 9, 2017 · 49296a9 · 49296a9
2 parents f489607 + 48636a3
commit 49296a9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/Makefile b/Makefile
@@ -18,11 +18,12 @@ define PROJECT_APP_EXTRA_KEYS
 	{broker_version_requirements, []}
 endef
 
-DEPS = amqp_client
+DEPS = amqp_client rabbit
 TEST_DEPS = amqp_client rabbitmq_ct_helpers rabbitmq_ct_client_helpers gun
 LOCAL_DEPS = public_key crypto ssl inets
 
-dep_amqp_client = git https://github.com/rabbitmq/rabbitmq-erlang-client rabbitmq_v3_6_5
+dep_amqp_client = git https://github.com/rabbitmq/rabbitmq-erlang-client stable
+dep_rabbit = git https://github.com/rabbitmq/rabbitmq-server stable
 
 DEP_PLUGINS = rabbit_common/mk/rabbitmq-plugin.mk
 

diff --git a/src/rabbit_vshovel_worker.erl b/src/rabbit_vshovel_worker.erl
@@ -306,7 +306,7 @@ publish(Tag, Method, Msg, State = #state{inbound_ch = InboundChan,
       end).
 
 make_conn_and_chan(URIs) ->
-    URI = lists:nth(random:uniform(length(URIs)), URIs),
+    URI = lists:nth(rand_compat:uniform(length(URIs)), URIs),
     {ok, AmqpParam} = amqp_uri:parse(URI),
     {ok, Conn} = amqp_connection:start(AmqpParam),
     link(Conn),