<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;}
@font-face
{font-family:Tahoma;
panose-1:2 11 6 4 3 5 4 4 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;}
p.MsoAcetate, li.MsoAcetate, div.MsoAcetate
{mso-style-priority:99;
mso-style-link:"Balloon Text Char";
margin:0in;
margin-bottom:.0001pt;
font-size:8.0pt;
font-family:"Tahoma","sans-serif";}
span.BalloonTextChar
{mso-style-name:"Balloon Text Char";
mso-style-priority:99;
mso-style-link:"Balloon Text";
font-family:"Tahoma","sans-serif";}
span.EmailStyle19
{mso-style-type:personal;
font-family:"Calibri","sans-serif";
color:windowtext;}
span.EmailStyle20
{mso-style-type:personal;
font-family:"Calibri","sans-serif";
color:#1F497D;}
span.EmailStyle21
{mso-style-type:personal;
font-family:"Calibri","sans-serif";
color:#1F497D;}
span.EmailStyle22
{mso-style-type:personal-reply;
font-family:"Calibri","sans-serif";
color:#1F497D;}
.MsoChpDefault
{mso-style-type:export-only;
font-size:10.0pt;}
@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"><span style="color:#1F497D">Well, after trying a bunch of things I found that I needed to add an exchange to the shovel configuration. I guess shovel publishes on the destination. My original understanding was that shovel moved messages
from one queue to another but this seems to be wrong. It seems to read a message from the source and publish it to the destination. In any case, messages are moving now and I can progress.<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"><o:p> </o:p></span></p>
<div>
<div style="border:none;border-top:solid #B5C4DF 1.0pt;padding:3.0pt 0in 0in 0in">
<p class="MsoNormal"><b><span style="font-size:10.0pt;font-family:"Tahoma","sans-serif"">From:</span></b><span style="font-size:10.0pt;font-family:"Tahoma","sans-serif""> rabbitmq-discuss-bounces@lists.rabbitmq.com [mailto:rabbitmq-discuss-bounces@lists.rabbitmq.com]
<b>On Behalf Of </b>Andy Gram<br>
<b>Sent:</b> Thursday, October 31, 2013 7:42 PM<br>
<b>To:</b> Discussions about RabbitMQ<br>
<b>Subject:</b> Re: [rabbitmq-discuss] messages stuck using shovel<o:p></o:p></span></p>
</div>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"><span style="color:#1F497D">And I should have provided this from devmid:<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"><o:p> </o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">[{ident_refresh,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {running,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {source,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_network,<<"guest">>,<<"guest">>,<<"/">>,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> "192.168.168.212",undefined,0,0,0,infinity,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [#Fun<amqp_uri.7.32597394>,#Fun<amqp_uri.7.32597394>],<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [],[]}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {destination,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_direct,<<"guest">>,none,<<"/">>,rabbit@devmid,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> []}}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {{2013,10,31},{17,32,2}}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">{ident_pub,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {running,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {source,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_direct,<<"guest">>,none,<<"/">>,rabbit@devmid,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> []}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {destination,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_network,<<"guest">>,<<"guest">>,<<"/">>,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> "192.168.168.212",undefined,0,0,0,infinity,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [#Fun<amqp_uri.7.32597394>,#Fun<amqp_uri.7.32597394>],<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [],[]}}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {{2013,10,31},{17,32,2}}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">{ident_sub,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {running,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {source,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_network,<<"guest">>,<<"guest">>,<<"/">>,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> "192.168.168.212",undefined,0,0,0,infinity,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [#Fun<amqp_uri.7.32597394>,#Fun<amqp_uri.7.32597394>],<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [],[]}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {destination,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_direct,<<"guest">>,none,<<"/">>,rabbit@devmid,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> []}}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {{2013,10,31},{17,32,2}}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">{refresh_req,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {running,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {source,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_direct,<<"guest">>,none,<<"/">>,rabbit@devmid,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> []}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {destination,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {amqp_params_network,<<"guest">>,<<"guest">>,<<"/">>,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> "192.168.168.212",undefined,0,0,0,infinity,none,<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [#Fun<amqp_uri.7.32597394>,#Fun<amqp_uri.7.32597394>],<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> [],[]}}},<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"> {{2013,10,31},{17,32,2}}}]<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">...done.<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"><o:p> </o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">IP address of devtop is 192.168.168.212. Here’s additional info from regarding connections from devtop;<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"><o:p> </o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">+-------+-----------------------------------------------+---------+----------------+----------+-----------+-----------------+------------------+-----------------+---------------+------------------+-------------------+--------------------+-----------------+-----------+------+------------+----------+----------+----------+----------+-----------+-------+------------+----------+------------------+--------------+---------+---------+-------+<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| vhost | name | type | auth_mechanism | channels | frame_max | host | last_blocked_age | last_blocked_by | node | peer_cert_issuer | peer_cert_subject
| peer_cert_validity | peer_host | peer_port | port | protocol | recv_cnt | recv_oct | send_cnt | send_oct | send_pend | ssl | ssl_cipher | ssl_hash | ssl_key_exchange | ssl_protocol | state | timeout | user |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">+-------+-----------------------------------------------+---------+----------------+----------+-----------+-----------------+------------------+-----------------+---------------+------------------+-------------------+--------------------+-----------------+-----------+------+------------+----------+----------+----------+----------+-----------+-------+------------+----------+------------------+--------------+---------+---------+-------+<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 127.0.0.1:53029 -> 127.0.0.1:5672 | network | PLAIN | 2 | 32768 | 127.0.0.1 | infinity | none | rabbit@devtop | |
| | 127.0.0.1 | 53029 | 5672 | AMQP 0-9-1 | 81 | 1888 | 69 | 2001 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 127.0.0.1:53030 -> 127.0.0.1:5672 | network | PLAIN | 2 | 32768 | 127.0.0.1 | infinity | none | rabbit@devtop | |
| | 127.0.0.1 | 53030 | 5672 | AMQP 0-9-1 | 67 | 926 | 66 | 964 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.142:38100 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.142 | 38100 | 5672 | AMQP 0-9-1 | 63 | 975 | 63 | 934 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.142:41887 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.142 | 41887 | 5672 | AMQP 0-9-1 | 64 | 951 | 64 | 1159 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.142:51473 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.142 | 51473 | 5672 | AMQP 0-9-1 | 64 | 967 | 63 | 924 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.142:58133 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.142 | 58133 | 5672 | AMQP 0-9-1 | 60 | 870 | 60 | 867 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.146:36800 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.146 | 36800 | 5672 | AMQP 0-9-1 | 64 | 967 | 63 | 924 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.146:37081 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.146 | 37081 | 5672 | AMQP 0-9-1 | 63 | 975 | 63 | 934 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.146:40113 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.146 | 40113 | 5672 | AMQP 0-9-1 | 63 | 951 | 64 | 1159 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">| / | 192.168.168.146:49883 -> 192.168.168.212:5672 | network | PLAIN | 1 | 131072 | 192.168.168.212 | infinity | none | rabbit@devtop | |
| | 192.168.168.146 | 49883 | 5672 | AMQP 0-9-1 | 61 | 1067 | 61 | 888 | 0 | False | | | | | running | 600 | guest |<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D">+-------+-----------------------------------------------+---------+----------------+----------+-----------+-----------------+------------------+-----------------+---------------+------------------+-------------------+--------------------+-----------------+-----------+------+------------+----------+----------+----------+----------+-----------+-------+------------+----------+------------------+--------------+---------+---------+-------+<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"><o:p> </o:p></span></p>
<div>
<div style="border:none;border-top:solid #B5C4DF 1.0pt;padding:3.0pt 0in 0in 0in">
<p class="MsoNormal"><b><span style="font-size:10.0pt;font-family:"Tahoma","sans-serif"">From:</span></b><span style="font-size:10.0pt;font-family:"Tahoma","sans-serif"">
<a href="mailto:rabbitmq-discuss-bounces@lists.rabbitmq.com">rabbitmq-discuss-bounces@lists.rabbitmq.com</a> [<a href="mailto:rabbitmq-discuss-bounces@lists.rabbitmq.com">mailto:rabbitmq-discuss-bounces@lists.rabbitmq.com</a>]
<b>On Behalf Of </b>Andy Gram<br>
<b>Sent:</b> Thursday, October 31, 2013 11:51 AM<br>
<b>To:</b> Discussions about RabbitMQ<br>
<b>Subject:</b> Re: [rabbitmq-discuss] messages stuck using shovel<o:p></o:p></span></p>
</div>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"><span style="color:#1F497D">I probably should have mentioned that I am using RabbitMQ R3.1.4 with Erlang R14B04 running on linux.<o:p></o:p></span></p>
<p class="MsoNormal"><span style="color:#1F497D"><o:p> </o:p></span></p>
<div>
<div style="border:none;border-top:solid #B5C4DF 1.0pt;padding:3.0pt 0in 0in 0in">
<p class="MsoNormal"><b><span style="font-size:10.0pt;font-family:"Tahoma","sans-serif"">From:</span></b><span style="font-size:10.0pt;font-family:"Tahoma","sans-serif"">
<a href="mailto:rabbitmq-discuss-bounces@lists.rabbitmq.com">rabbitmq-discuss-bounces@lists.rabbitmq.com</a> [<a href="mailto:rabbitmq-discuss-bounces@lists.rabbitmq.com">mailto:rabbitmq-discuss-bounces@lists.rabbitmq.com</a>]
<b>On Behalf Of </b>Andy Gram<br>
<b>Sent:</b> Thursday, October 31, 2013 11:10 AM<br>
<b>To:</b> <a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<b>Subject:</b> [rabbitmq-discuss] messages stuck using shovel<o:p></o:p></span></p>
</div>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<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/">www.blackridge.us</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>