<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:m="http://schemas.microsoft.com/office/2004/12/omml" xmlns="http://www.w3.org/TR/REC-html40">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=us-ascii">
<meta name="Generator" content="Microsoft Word 14 (filtered medium)">
<style><!--
/* Font Definitions */
@font-face
{font-family:Calibri;
panose-1:2 15 5 2 2 2 4 3 2 4;}
/* Style Definitions */
p.MsoNormal, li.MsoNormal, div.MsoNormal
{margin:0in;
margin-bottom:.0001pt;
font-size:11.0pt;
font-family:"Calibri","sans-serif";}
a:link, span.MsoHyperlink
{mso-style-priority:99;
color:blue;
text-decoration:underline;}
a:visited, span.MsoHyperlinkFollowed
{mso-style-priority:99;
color:purple;
text-decoration:underline;}
span.EmailStyle17
{mso-style-type:personal-compose;
font-family:"Calibri","sans-serif";
color:windowtext;}
.MsoChpDefault
{mso-style-type:export-only;
font-family:"Calibri","sans-serif";}
@page WordSection1
{size:8.5in 11.0in;
margin:1.0in 1.0in 1.0in 1.0in;}
div.WordSection1
{page:WordSection1;}
--></style><!--[if gte mso 9]><xml>
<o:shapedefaults v:ext="edit" spidmax="1026" />
</xml><![endif]--><!--[if gte mso 9]><xml>
<o:shapelayout v:ext="edit">
<o:idmap v:ext="edit" data="1" />
</o:shapelayout></xml><![endif]-->
</head>
<body lang="EN-US" link="blue" vlink="purple">
<div class="WordSection1">
<p class="MsoNormal">I have a configuration of 3 RabbitMQ nodes; devtop, devmid, devbot. I am implementing a star configuration with devtop as the center of the start. This is a pubsub application over a WAN. Any node can submit a new item to devtop and my
publisher application will publish to all nodes, including itself. I am using shovel to instantiate a queue for each node that is bound to a fanout exchange on devtop. The published messages are stuck on devtop as below;<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">+-------+--------------------------------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------+--------+---------+<o:p></o:p></p>
<p class="MsoNormal">| vhost | name | auto_delete | consumers | durable | exclusive_consumer_tag | idle_since | memory | messages | messages_ready | messages_unacknowledged | node | policy | status |<o:p></o:p></p>
<p class="MsoNormal">+-------+--------------------------------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------+--------+---------+<o:p></o:p></p>
<p class="MsoNormal">| / | amq.gen-QXyScDVGCoTv8bhcbrMOrA | False | 1 | False | | 2013-10-31 10:32:25 | 9456 | 1 | 0 | 1 | rabbit@devtop | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | amq.gen-Ya03CVYcY-CEVKOYcSt0Xw | False | 1 | False | | 2013-10-31 10:32:25 | 9456 | 1 | 0 | 1 | rabbit@devtop | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | new_ident_queue | False | 1 | True | | 2013-10-31 10:32:28 | 14312 | 0 | 0 | 0 | rabbit@devtop | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | pub_idents | False | 0 | True | | 2013-10-31 10:15:52 | 13760 | 0 | 0 | 0 | rabbit@devtop | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | refresh_idents | False | 2 | True | | 2013-10-31 10:32:18 | 14192 | 0 | 0 | 0 | rabbit@devtop | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | refresh_queue | False | 1 | True | | 2013-10-31 10:32:18 | 13976 | 0 | 0 | 0 | rabbit@devtop | | running |<o:p></o:p></p>
<p class="MsoNormal">+-------+--------------------------------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------+--------+---------+<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">The status on devmid is as follows;<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">+-------+-----------------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------+--------+---------+<o:p></o:p></p>
<p class="MsoNormal">| vhost | name | auto_delete | consumers | durable | exclusive_consumer_tag | idle_since | memory | messages | messages_ready | messages_unacknowledged | node | policy | status |<o:p></o:p></p>
<p class="MsoNormal">+-------+-----------------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------+--------+---------+<o:p></o:p></p>
<p class="MsoNormal">| / | ident_updates | False | 0 | True | | 2013-10-31 17:32:03 | 21696 | 0 | 0 | 0 | rabbit@devmid | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | new_ident_queue | False | 1 | True | | 2013-10-31 17:32:03 | 21912 | 0 | 0 | 0 | rabbit@devmid | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | refresh_idents | False | 0 | True | | 2013-10-31 17:32:03 | 21696 | 0 | 0 | 0 | rabbit@devmid | | running |<o:p></o:p></p>
<p class="MsoNormal">| / | refresh_queue | False | 1 | True | | 2013-10-31 17:32:03 | 21912 | 0 | 0 | 0 | rabbit@devmid | | running |<o:p></o:p></p>
<p class="MsoNormal">+-------+-----------------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------+--------+---------+<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">I am expecting shovel from devmid to move the messages from devtop queue to ident_updates queue on devmid. My shovel configuration follows:<o:p></o:p></p>
<p class="MsoNormal">{rabbitmq_shovel,<o:p></o:p></p>
<p class="MsoNormal"> [ {shovels, [ {ident_pub,<o:p></o:p></p>
<p class="MsoNormal"> [ {sources, [ {broker, "amqp://"}<o:p></o:p></p>
<p class="MsoNormal"> , {declarations, [<o:p></o:p></p>
<p class="MsoNormal"> {'queue.declare',<o:p></o:p></p>
<p class="MsoNormal"> [{queue, <<"new_ident_queue">> }<o:p></o:p></p>
<p class="MsoNormal"> , durable<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> , {destinations, [ {broker, "amqp://192.168.168.212"}<o:p></o:p></p>
<p class="MsoNormal"> , {declarations, [<o:p></o:p></p>
<p class="MsoNormal"> {'queue.declare',<o:p></o:p></p>
<p class="MsoNormal"> [{queue, <<"new_ident_queue">> }<o:p></o:p></p>
<p class="MsoNormal"> , durable<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> , {queue, <<"new_ident_queue">>}<o:p></o:p></p>
<p class="MsoNormal"> , {prefetch_count, 1}<o:p></o:p></p>
<p class="MsoNormal"> , {ack_mode, on_confirm}<o:p></o:p></p>
<p class="MsoNormal"> , {publish_properties, [ {delivery_mode, 2} ]}<o:p></o:p></p>
<p class="MsoNormal"> , {reconnect_delay, 5}<o:p></o:p></p>
<p class="MsoNormal"> ]},<o:p></o:p></p>
<p class="MsoNormal"> {ident_sub,<o:p></o:p></p>
<p class="MsoNormal"> [ {destinations, [ {broker, "amqp://"}<o:p></o:p></p>
<p class="MsoNormal"> , {declarations, [<o:p></o:p></p>
<p class="MsoNormal"> {'queue.declare',<o:p></o:p></p>
<p class="MsoNormal"> [{queue, <<"ident_updates">> }<o:p></o:p></p>
<p class="MsoNormal"> , durable<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> , {sources, [ {broker, "amqp://192.168.168.212"}<o:p></o:p></p>
<p class="MsoNormal"> , {declarations, [ {'exchange.declare',<o:p></o:p></p>
<p class="MsoNormal"> [ {exchange, <<"pub_idents">>}<o:p></o:p></p>
<p class="MsoNormal"> , {type, <<"fanout">>}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> , {'queue.declare',<o:p></o:p></p>
<p class="MsoNormal"> [{queue, <<>> }<o:p></o:p></p>
<p class="MsoNormal"> , exclusive<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> , {'queue.bind',<o:p></o:p></p>
<p class="MsoNormal"> [ {exchange, <<"pub_idents">>}<o:p></o:p></p>
<p class="MsoNormal"> , {queue, <<>>}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> ]}<o:p></o:p></p>
<p class="MsoNormal"> , {queue, <<>>}<o:p></o:p></p>
<p class="MsoNormal"> , {prefetch_count, 1}<o:p></o:p></p>
<p class="MsoNormal"> , {ack_mode, on_confirm}<o:p></o:p></p>
<p class="MsoNormal"> , {publish_properties, [ {delivery_mode, 2} ]}<o:p></o:p></p>
<p class="MsoNormal"> , {reconnect_delay, 5}<o:p></o:p></p>
<p class="MsoNormal"> ]},<o:p></o:p></p>
<p class="MsoNormal">…<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">My shovel is stuck!! Any help would be appreciated.<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">Thanks,<o:p></o:p></p>
<p class="MsoNormal">Andy<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">This email message is for the sole use of the intended recipient(s) and may contain confidential and privileged information. Any unauthorized review, use, disclosure or distribution is prohibited. If you are not the intended recipient,
please contact the sender by reply email and destroy all copies of the original message. If you are the intended recipient, please be advised that the content of this message is subject to access, review and disclosure by the sender's Email System Administrator.<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">Andy Gram<o:p></o:p></p>
<p class="MsoNormal">BlackRidge Technology Inc. <o:p></o:p></p>
<p class="MsoNormal"><a href="http://www.blackridge.us/"><span style="color:blue">www.blackridge.us</span></a><o:p></o:p></p>
<p class="MsoNormal">408-892-4044<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
</div>
</body>
</html>