title: RabbitMQ Shovel failed to connect
body: <p>I have 2 rabbitmq box named : centos (192.168.1.115) and devserver (192.168.1.126)</p>
  
  <p>in 'centos' I have :</p>
  
  <p>I have queue named : toshovel bound to a topic exchange with routing key '#'
  I test posting to the exchange and messages transfered to that queue.</p>
  
  <p>In 'devserver' I have :
  1. topic exchange named bino.topic
  2. queue named : bino.nms.idc3d bound to bino.topic
  This also tested. including using pika to publish message from 'centos' to 'devserver' so that I'm sure there is no firewall nor permition nor authentication (user/password : esx/esx) problem </p>
  
  <p>Now I want to shovel from 'centos' to 'devserver'</p>
  
  <p>I tried adding shovel in 'centos' per <a href="https://www.rabbitmq.com/shovel-dynamic.html" rel="nofollow noreferrer">https://www.rabbitmq.com/shovel-dynamic.html</a></p>
  
  <p>rabbitmqctl set_parameter shovel my-shovel '{"src-protocol": "amqp091", "src-uri": "amqp://esx:esx@192.168.1.115", "src-queue": "toshovel", "dest-protocol": "amqp091", "dest-uri": "amqp://esx:esx@192.168.126/", "dest-queue": "bino.nms.idc3d"}'</p>
  
  <p>but the centos log said</p>
  
  <p>from : /var/log/rabbitmq/rabbit\@centos.log</p>
  
  <pre><code>2018-06-20 14:03:21.800 [info] &lt;0.735.0&gt; terminating static worker with {timeout,{gen_server,call,[&lt;0.763.0&gt;,connect,60000]}} 
  2018-06-20 14:03:21.800 [error] &lt;0.735.0&gt; ** Generic server &lt;0.735.0&gt; terminating
  ** Last message in was {'$gen_cast',init}
  ** When Server state == {state,undefined,undefined,undefined,undefined,{&lt;&lt;"/"&gt;&gt;,&lt;&lt;"my-shovel"&gt;&gt;},dynamic,#{ack_mode =&gt; on_confirm,dest =&gt; #{dest_queue =&gt; &lt;&lt;"bino.nms.idc3d"&gt;&gt;,fields_fun =&gt; #Fun&lt;rabbit_shovel_parameters.11.26683091&gt;,module =&gt; rabbit_amqp091_shovel,props_fun =&gt; #Fun&lt;rabbit_shovel_parameters.12.26683091&gt;,resource_decl =&gt; #Fun&lt;rabbit_shovel_parameters.10.26683091&gt;,uris =&gt; ["amqp://esx:esx@192.168.126/"]},name =&gt; &lt;&lt;"my-shovel"&gt;&gt;,reconnect_delay =&gt; 5,shovel_type =&gt; dynamic,source =&gt; #{delete_after =&gt; never,module =&gt; rabbit_amqp091_shovel,prefetch_count =&gt; 1000,queue =&gt; &lt;&lt;"toshovel"&gt;&gt;,resource_decl =&gt; #Fun&lt;rabbit_shovel_parameters.14.26683091&gt;,source_exchange_key =&gt; &lt;&lt;&gt;&gt;,uris =&gt; ["amqp://esx:esx@192.168.1.115"]}},undefined,undefined,undefined,undefined,undefined}
  ** Reason for termination == 
  ** {timeout,{gen_server,call,[&lt;0.763.0&gt;,connect,60000]}}
  2018-06-20 14:03:21.800 [warning] &lt;0.743.0&gt; closing AMQP connection &lt;0.743.0&gt; (192.168.1.115:48223 -&gt; 192.168.1.115:5672 - Shovel my-shovel, vhost: '/', user: 'esx'):
  client unexpectedly closed TCP connection
  2018-06-20 14:03:21.800 [error] &lt;0.735.0&gt; CRASH REPORT Process &lt;0.735.0&gt; with 1 neighbours exited with reason: {timeout,{gen_server,call,[&lt;0.763.0&gt;,connect,60000]}} in gen_server2:terminate/3 line 1166
  2018-06-20 14:03:21.801 [error] &lt;0.410.0&gt; Supervisor {&lt;0.410.0&gt;,rabbit_shovel_dyn_worker_sup} had child {&lt;&lt;"/"&gt;&gt;,&lt;&lt;"my-shovel"&gt;&gt;} started with rabbit_shovel_worker:start_link(dynamic, {&lt;&lt;"/"&gt;&gt;,&lt;&lt;"my-shovel"&gt;&gt;}, [{&lt;&lt;"dest-protocol"&gt;&gt;,&lt;&lt;"amqp091"&gt;&gt;},{&lt;&lt;"dest-queue"&gt;&gt;,&lt;&lt;"bino.nms.idc3d"&gt;&gt;},{&lt;&lt;"dest-uri"&gt;&gt;,&lt;&lt;"a..."&gt;&gt;},...]) at &lt;0.735.0&gt; exit with reason {timeout,{gen_server,call,[&lt;0.763.0&gt;,connect,60000]}} in context child_terminated
  2018-06-20 14:03:21.802 [error] &lt;0.738.0&gt; ** Generic server &lt;0.738.0&gt; terminating 
  ** Last message in was {'EXIT',&lt;0.735.0&gt;,{timeout,{gen_server,call,[&lt;0.763.0&gt;,connect,60000]}}}
  ** When Server state == {state,amqp_network_connection,{state,#Port&lt;0.29325&gt;,&lt;&lt;"client 192.168.1.115:48223 -&gt; 192.168.1.115:5672"&gt;&gt;,10,&lt;0.744.0&gt;,131072,&lt;0.737.0&gt;,undefined,false},&lt;0.742.0&gt;,{amqp_params_network,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"/"&gt;&gt;,"192.168.1.115",5672,2047,0,10,60000,none,[#Fun&lt;amqp_uri.12.90191702&gt;,#Fun&lt;amqp_uri.12.90191702&gt;],[{&lt;&lt;"connection_name"&gt;&gt;,longstr,&lt;&lt;"Shovel my-shovel"&gt;&gt;}],[]},2047,[{&lt;&lt;"capabilities"&gt;&gt;,table,[{&lt;&lt;"publisher_confirms"&gt;&gt;,bool,true},{&lt;&lt;"exchange_exchange_bindings"&gt;&gt;,bool,true},{&lt;&lt;"basic.nack"&gt;&gt;,bool,true},{&lt;&lt;"consumer_cancel_notify"&gt;&gt;,bool,true},{&lt;&lt;"connection.blocked"&gt;&gt;,bool,true},{&lt;&lt;"consumer_priorities"&gt;&gt;,bool,true},{&lt;&lt;"authentication_failure_close"&gt;&gt;,bool,true},{&lt;&lt;"per_consumer_qos"&gt;&gt;,bool,true},{&lt;&lt;"direct_reply_to"&gt;&gt;,bool,true}]},{&lt;&lt;"cluster_name"&gt;&gt;,longstr,&lt;&lt;"rabbit@centos"&gt;&gt;},{&lt;&lt;"copyright"&gt;&gt;,longstr,&lt;&lt;"Copyright (C) 2007-2018 Pivotal Software, Inc."&gt;&gt;},{&lt;&lt;"information"&gt;&gt;,longstr,&lt;&lt;"Licensed under the MPL.  See http://www.rabbitmq.com/"&gt;&gt;},{&lt;&lt;"platform"&gt;&gt;,longstr,&lt;&lt;"Erlang/OTP 20.3.4"&gt;&gt;},{&lt;&lt;"product"&gt;&gt;,longstr,&lt;&lt;"RabbitMQ"&gt;&gt;},{&lt;&lt;"version"&gt;&gt;,longstr,&lt;&lt;"3.7.5"&gt;&gt;}],none,false}
  ** Reason for termination == 
  ** "stopping because dependent process &lt;0.735.0&gt; died: {timeout,\n                                                    {gen_server,call,\n                                                     [&lt;0.763.0&gt;,connect,\n                                                      60000]}}"
  2018-06-20 14:03:21.802 [error] &lt;0.738.0&gt; CRASH REPORT Process &lt;0.738.0&gt; with 0 neighbours exited with reason: "stopping because dependent process &lt;0.735.0&gt; died: {timeout,\n                                                    {gen_server,call,\n                                                     [&lt;0.763.0&gt;,connect,\n                                                      60000]}}" in gen_server:handle_common_reply/8 line 726
  2018-06-20 14:03:21.802 [error] &lt;0.752.0&gt; Supervisor {&lt;0.752.0&gt;,amqp_channel_sup} had child channel started with amqp_channel:start_link(network, &lt;0.738.0&gt;, 1, &lt;0.753.0&gt;, {&lt;&lt;"client 192.168.1.115:48223 -&gt; 192.168.1.115:5672"&gt;&gt;,1}) at &lt;0.755.0&gt; exit with reason {timeout,{gen_server,call,[&lt;0.763.0&gt;,connect,60000]}} in context child_terminated
  2018-06-20 14:03:21.802 [error] &lt;0.752.0&gt; Supervisor {&lt;0.752.0&gt;,amqp_channel_sup} had child channel started with amqp_channel:start_link(network, &lt;0.738.0&gt;, 1, &lt;0.753.0&gt;, {&lt;&lt;"client 192.168.1.115:48223 -&gt; 192.168.1.115:5672"&gt;&gt;,1}) at &lt;0.755.0&gt; exit with reason reached_max_restart_intensity in context shutdown
  2018-06-20 14:03:21.803 [error] &lt;0.736.0&gt; Supervisor {&lt;0.736.0&gt;,amqp_connection_sup} had child connection started with amqp_gen_connection:start_link(&lt;0.737.0&gt;, {amqp_params_network,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"/"&gt;&gt;,"192.168.1.115",5672,2047,0,10,60000,none,[#Fun&lt;am..&gt;,...],...}) at &lt;0.738.0&gt; exit with reason "stopping because dependent process &lt;0.735.0&gt; died: {timeout,\n                                                    {gen_server,call,\n                                                     [&lt;0.763.0&gt;,connect,\n                                                      60000]}}" in context child_terminated
  2018-06-20 14:03:21.803 [error] &lt;0.736.0&gt; Supervisor {&lt;0.736.0&gt;,amqp_connection_sup} had child connection started with amqp_gen_connection:start_link(&lt;0.737.0&gt;, {amqp_params_network,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"/"&gt;&gt;,"192.168.1.115",5672,2047,0,10,60000,none,[#Fun&lt;am..&gt;,...],...}) at &lt;0.738.0&gt; exit with reason reached_max_restart_intensity in context shutdown
  2018-06-20 14:03:26.865 [info] &lt;0.835.0&gt; accepting AMQP connection &lt;0.835.0&gt; (192.168.1.115:47801 -&gt; 192.168.1.115:5672)
  2018-06-20 14:03:26.934 [info] &lt;0.835.0&gt; Connection &lt;0.835.0&gt; (192.168.1.115:47801 -&gt; 192.168.1.115:5672) has a client-provided name: Shovel my-shovel
  2018-06-20 14:03:26.935 [info] &lt;0.835.0&gt; connection &lt;0.835.0&gt; (192.168.1.115:47801 -&gt; 192.168.1.115:5672 - Shovel my-shovel): user 'esx' authenticated and granted access to vhost '/'
  2018-06-20 14:04:26.938 [info] &lt;0.827.0&gt; terminating static worker with {timeout,{gen_server,call,[&lt;0.855.0&gt;,connect,60000]}} 
  2018-06-20 14:04:26.938 [error] &lt;0.827.0&gt; ** Generic server &lt;0.827.0&gt; terminating
  ** Last message in was {'$gen_cast',init}
  ** When Server state == {state,undefined,undefined,undefined,undefined,{&lt;&lt;"/"&gt;&gt;,&lt;&lt;"my-shovel"&gt;&gt;},dynamic,#{ack_mode =&gt; on_confirm,dest =&gt; #{dest_queue =&gt; &lt;&lt;"bino.nms.idc3d"&gt;&gt;,fields_fun =&gt; #Fun&lt;rabbit_shovel_parameters.11.26683091&gt;,module =&gt; rabbit_amqp091_shovel,props_fun =&gt; #Fun&lt;rabbit_shovel_parameters.12.26683091&gt;,resource_decl =&gt; #Fun&lt;rabbit_shovel_parameters.10.26683091&gt;,uris =&gt; ["amqp://esx:esx@192.168.126/"]},name =&gt; &lt;&lt;"my-shovel"&gt;&gt;,reconnect_delay =&gt; 5,shovel_type =&gt; dynamic,source =&gt; #{delete_after =&gt; never,module =&gt; rabbit_amqp091_shovel,prefetch_count =&gt; 1000,queue =&gt; &lt;&lt;"toshovel"&gt;&gt;,resource_decl =&gt; #Fun&lt;rabbit_shovel_parameters.14.26683091&gt;,source_exchange_key =&gt; &lt;&lt;&gt;&gt;,uris =&gt; ["amqp://esx:esx@192.168.1.115"]}},undefined,undefined,undefined,undefined,undefined}
  ** Reason for termination == 
  ** {timeout,{gen_server,call,[&lt;0.855.0&gt;,connect,60000]}}
  2018-06-20 14:04:26.939 [warning] &lt;0.835.0&gt; closing AMQP connection &lt;0.835.0&gt; (192.168.1.115:47801 -&gt; 192.168.1.115:5672 - Shovel my-shovel, vhost: '/', user: 'esx'):
  client unexpectedly closed TCP connection
  2018-06-20 14:04:26.939 [error] &lt;0.827.0&gt; CRASH REPORT Process &lt;0.827.0&gt; with 1 neighbours exited with reason: {timeout,{gen_server,call,[&lt;0.855.0&gt;,connect,60000]}} in gen_server2:terminate/3 line 1166
  2018-06-20 14:04:26.939 [error] &lt;0.410.0&gt; Supervisor {&lt;0.410.0&gt;,rabbit_shovel_dyn_worker_sup} had child {&lt;&lt;"/"&gt;&gt;,&lt;&lt;"my-shovel"&gt;&gt;} started with rabbit_shovel_worker:start_link(dynamic, {&lt;&lt;"/"&gt;&gt;,&lt;&lt;"my-shovel"&gt;&gt;}, [{&lt;&lt;"dest-protocol"&gt;&gt;,&lt;&lt;"amqp091"&gt;&gt;},{&lt;&lt;"dest-queue"&gt;&gt;,&lt;&lt;"bino.nms.idc3d"&gt;&gt;},{&lt;&lt;"dest-uri"&gt;&gt;,&lt;&lt;"a..."&gt;&gt;},...]) at &lt;0.827.0&gt; exit with reason {timeout,{gen_server,call,[&lt;0.855.0&gt;,connect,60000]}} in context child_terminated
  2018-06-20 14:04:26.940 [error] &lt;0.830.0&gt; ** Generic server &lt;0.830.0&gt; terminating 
  ** Last message in was {'EXIT',&lt;0.827.0&gt;,{timeout,{gen_server,call,[&lt;0.855.0&gt;,connect,60000]}}}
  ** When Server state == {state,amqp_network_connection,{state,#Port&lt;0.29425&gt;,&lt;&lt;"client 192.168.1.115:47801 -&gt; 192.168.1.115:5672"&gt;&gt;,10,&lt;0.836.0&gt;,131072,&lt;0.829.0&gt;,undefined,false},&lt;0.834.0&gt;,{amqp_params_network,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"/"&gt;&gt;,"192.168.1.115",5672,2047,0,10,60000,none,[#Fun&lt;amqp_uri.12.90191702&gt;,#Fun&lt;amqp_uri.12.90191702&gt;],[{&lt;&lt;"connection_name"&gt;&gt;,longstr,&lt;&lt;"Shovel my-shovel"&gt;&gt;}],[]},2047,[{&lt;&lt;"capabilities"&gt;&gt;,table,[{&lt;&lt;"publisher_confirms"&gt;&gt;,bool,true},{&lt;&lt;"exchange_exchange_bindings"&gt;&gt;,bool,true},{&lt;&lt;"basic.nack"&gt;&gt;,bool,true},{&lt;&lt;"consumer_cancel_notify"&gt;&gt;,bool,true},{&lt;&lt;"connection.blocked"&gt;&gt;,bool,true},{&lt;&lt;"consumer_priorities"&gt;&gt;,bool,true},{&lt;&lt;"authentication_failure_close"&gt;&gt;,bool,true},{&lt;&lt;"per_consumer_qos"&gt;&gt;,bool,true},{&lt;&lt;"direct_reply_to"&gt;&gt;,bool,true}]},{&lt;&lt;"cluster_name"&gt;&gt;,longstr,&lt;&lt;"rabbit@centos"&gt;&gt;},{&lt;&lt;"copyright"&gt;&gt;,longstr,&lt;&lt;"Copyright (C) 2007-2018 Pivotal Software, Inc."&gt;&gt;},{&lt;&lt;"information"&gt;&gt;,longstr,&lt;&lt;"Licensed under the MPL.  See http://www.rabbitmq.com/"&gt;&gt;},{&lt;&lt;"platform"&gt;&gt;,longstr,&lt;&lt;"Erlang/OTP 20.3.4"&gt;&gt;},{&lt;&lt;"product"&gt;&gt;,longstr,&lt;&lt;"RabbitMQ"&gt;&gt;},{&lt;&lt;"version"&gt;&gt;,longstr,&lt;&lt;"3.7.5"&gt;&gt;}],none,false}
  ** Reason for termination == 
  ** "stopping because dependent process &lt;0.827.0&gt; died: {timeout,\n                                                    {gen_server,call,\n                                                     [&lt;0.855.0&gt;,connect,\n                                                      60000]}}"
  2018-06-20 14:04:26.940 [error] &lt;0.830.0&gt; CRASH REPORT Process &lt;0.830.0&gt; with 0 neighbours exited with reason: "stopping because dependent process &lt;0.827.0&gt; died: {timeout,\n                                                    {gen_server,call,\n                                                     [&lt;0.855.0&gt;,connect,\n                                                      60000]}}" in gen_server:handle_common_reply/8 line 726
  2018-06-20 14:04:26.941 [error] &lt;0.844.0&gt; Supervisor {&lt;0.844.0&gt;,amqp_channel_sup} had child channel started with amqp_channel:start_link(network, &lt;0.830.0&gt;, 1, &lt;0.846.0&gt;, {&lt;&lt;"client 192.168.1.115:47801 -&gt; 192.168.1.115:5672"&gt;&gt;,1}) at &lt;0.847.0&gt; exit with reason {timeout,{gen_server,call,[&lt;0.855.0&gt;,connect,60000]}} in context child_terminated
  2018-06-20 14:04:26.941 [error] &lt;0.844.0&gt; Supervisor {&lt;0.844.0&gt;,amqp_channel_sup} had child channel started with amqp_channel:start_link(network, &lt;0.830.0&gt;, 1, &lt;0.846.0&gt;, {&lt;&lt;"client 192.168.1.115:47801 -&gt; 192.168.1.115:5672"&gt;&gt;,1}) at &lt;0.847.0&gt; exit with reason reached_max_restart_intensity in context shutdown
  2018-06-20 14:04:26.941 [error] &lt;0.828.0&gt; Supervisor {&lt;0.828.0&gt;,amqp_connection_sup} had child connection started with amqp_gen_connection:start_link(&lt;0.829.0&gt;, {amqp_params_network,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"/"&gt;&gt;,"192.168.1.115",5672,2047,0,10,60000,none,[#Fun&lt;am..&gt;,...],...}) at &lt;0.830.0&gt; exit with reason "stopping because dependent process &lt;0.827.0&gt; died: {timeout,\n                                                    {gen_server,call,\n                                                     [&lt;0.855.0&gt;,connect,\n                                                      60000]}}" in context child_terminated
  2018-06-20 14:04:26.942 [error] &lt;0.828.0&gt; Supervisor {&lt;0.828.0&gt;,amqp_connection_sup} had child connection started with amqp_gen_connection:start_link(&lt;0.829.0&gt;, {amqp_params_network,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"/"&gt;&gt;,"192.168.1.115",5672,2047,0,10,60000,none,[#Fun&lt;am..&gt;,...],...}) at &lt;0.830.0&gt; exit with reason reached_max_restart_intensity in context shutdown
  </code></pre>
  
  <p>from /var/log/rabbitmq/log/crash.log</p>
  
  <pre><code>2018-06-20 14:04:40 =SUPERVISOR REPORT====
       Supervisor: {&lt;0.914.0&gt;,amqp_connection_sup}
       Context:    shutdown
       Reason:     reached_max_restart_intensity
       Offender:   [{pid,&lt;0.916.0&gt;},{name,connection},{mfargs,{amqp_gen_connection,start_link,[&lt;0.915.0&gt;,{amqp_params_network,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"esx"&gt;&gt;,&lt;&lt;"/"&gt;&gt;,"192.168.1.115",5672,2047,0,10,60000,none,[#Fun&lt;amqp_uri.12.90191702&gt;,#Fun&lt;amqp_uri.12.90191702&gt;],[{&lt;&lt;"connection_name"&gt;&gt;,longstr,&lt;&lt;"Shovel my-shovel"&gt;&gt;}],[]}]}},{restart_type,intrinsic},{shutdown,brutal_kill},{child_type,worker}]
  </code></pre>
  
  <p>Kindly please give me some clue</p>