Hi Alexandru,<div><br></div><div>I still have the same issue going on. &nbsp;Here's a recap:</div><div><br></div><div><ul><li><span class="Apple-style-span" style="line-height: normal; ">I have upgraded to the latest stable (2.7.0) Rabbmitmq on all nodes.</span></li><li><span class="Apple-style-span" style="line-height: normal; ">Messages which should be shoveled to a remote broker stay unacknowledged in the queue which Shovel is using as a source.</span></li><li><span class="Apple-style-span" style="line-height: normal; ">Restarting RabbitMQ on that moment isn't possible. &nbsp;Killing is required, often having to issue "epmd -kill"</span></li><li><span class="Apple-style-span" style="line-height: normal; ">When restarting RabbitMQ containing Shovel after that all messages are shoveled correctly to their destination.</span></li><li><span class="Apple-style-span" style="line-height: normal; ">ack_mode has value "on_confirm", when changing this to "no_ack" all messages get lost.</span></li></ul><div><span class="Apple-style-span" style="line-height: 16px;">I must say that it's possible that small network interruptions happen, or occasional packetloss occurs... but that doesn't explain that restarting Rabbit, makes all messages arrive.</span></div><div><span class="Apple-style-span" style="line-height: 16px;"><br></span></div><div><span class="Apple-style-span" style="line-height: 16px;">Here's my complete Shovel configuration (I replaced hostnames &amp; queue names):</span></div></div><div><span class="Apple-style-span" style="line-height: 16px;"><br></span></div><div><span class="Apple-style-span" style="line-height: 16px;"><div><font class="Apple-style-span" face="'courier new', monospace">[{rabbitmq_shovel,</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; [{shovels,</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; [</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp;{scan_orders_amsterdam,</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; [{sources, &nbsp; &nbsp; &nbsp;[{broker,"amqp://localhost"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{destinations, [{broker, "amqp://server01"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{queue, &lt;&lt;"messages_server01"&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{ack_mode, on_confirm},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_properties, [{delivery_mode, 2}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_fields, [{exchange, &lt;&lt;""&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;{routing_key, &lt;&lt;"assignments"&gt;&gt;}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{reconnect_delay, 5}</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; ]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp;{scan_orders_gent,</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; [{sources, &nbsp; &nbsp; &nbsp;[{broker,"amqp://localhost"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{destinations, [{broker, "amqp://server02"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{queue, &lt;&lt;"messages_server02"&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{ack_mode, on_confirm},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_properties, [{delivery_mode, 2}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_fields, [{exchange, &lt;&lt;""&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;{routing_key, &lt;&lt;"assignments"&gt;&gt;}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{reconnect_delay, 5}</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; ]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp;{scan_orders_lebanon,</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; [{sources, &nbsp; &nbsp; &nbsp;[{broker,"amqp://localhost"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{destinations, [{broker, "amqp://server03"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{queue, &lt;&lt;"messages_server03"&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{ack_mode, on_confirm},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_properties, [{delivery_mode, 2}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_fields, [{exchange, &lt;&lt;""&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;{routing_key, &lt;&lt;"assignments"&gt;&gt;}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{reconnect_delay, 5}</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; ]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp;{scan_orders_pune,</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; [{sources, &nbsp; &nbsp; &nbsp;[{broker,"amqp://localhost"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{destinations, [{broker, "amqp://server04"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{queue, &lt;&lt;"messages_server04"&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{ack_mode, on_confirm},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_properties, [{delivery_mode, 2}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_fields, [{exchange, &lt;&lt;""&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;{routing_key, &lt;&lt;"assignments"&gt;&gt;}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{reconnect_delay, 5}</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; ]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp;{scan_orders_lodz,</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; [{sources, &nbsp; &nbsp; &nbsp;[{broker,"amqp://localhost"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{destinations, [{broker, "amqp://server05"}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{queue, &lt;&lt;"messages_server05"&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{ack_mode, on_confirm},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_properties, [{delivery_mode, 2}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{publish_fields, [{exchange, &lt;&lt;""&gt;&gt;},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;{routing_key, &lt;&lt;"assignments"&gt;&gt;}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; &nbsp;{reconnect_delay, 5}</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp; ]}</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp; &nbsp;]</font></div><div><font class="Apple-style-span" face="'courier new', monospace">&nbsp; &nbsp;}]</font></div><div><font class="Apple-style-span" face="'courier new', monospace">}].</font></div><div><br></div><div><br></div><div>Any idea how to troubleshoot this?</div><div><br></div><div>Cheers,</div><div><br></div><div>Jelle</div><div><br></div></span></div><div><br></div><div><br></div>