<div dir="ltr">Rabbit version in use is: RabbitMQ 3.2.1, Erlang R14B04<br><br>rabbitmqctl report on <div>upstream: <a href="http://pastebin.com/PNqTziGk">http://pastebin.com/PNqTziGk</a></div><div>"slave" server: <a href="http://pastebin.com/4L6JFsiW">http://pastebin.com/4L6JFsiW</a></div>
<div><br></div><div><b>I have this in the exchanges list on the upstream:</b></div><div><br></div><div><table class="" style="border-collapse:collapse;border-width:1px;border-bottom-style:solid;border-bottom-color:rgb(204,204,204);margin-bottom:0px;font-family:Verdana,sans-serif">
<tbody><tr class="" style="color:rgb(170,170,170)"><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(248,248,248)),to(rgb(255,255,255)))">
<a href="http://rabbit1:15672/#/exchanges/%2F/federation%3A%20users%20-%3E%20rabbit%40rabbit3.c.rabbit-magic.internal%20B" title="This is used internally by the federation mechanism." style="display:block;width:408px;color:rgb(170,170,170);font-weight:bold;text-decoration:none">federation: users -> rabbit@rabbit3.c.rabbit-magic.internal B</a></td>
<td class="" style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(248,248,248)),to(rgb(255,255,255)));text-align:center!important">
x-federation-upstream</td><td class="" style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(248,248,248)),to(rgb(255,255,255)));text-align:center!important">
ha-all</td><td class="" style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(248,248,248)),to(rgb(255,255,255)));text-align:center!important">
<acronym title="durable: true" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">D</acronym> <acronym title="auto-delete: true" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">AD</acronym> <acronym title="internal: true" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">I</acronym> <acronym title="x-max-hops: 1, x-internal-purpose: federation" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">Args<br>
<br></acronym></td></tr></tbody></table><br>And this i the queues list:</div><div><br></div><div><table class="" style="border-collapse:collapse;border-width:1px;border-bottom-style:solid;border-bottom-color:rgb(204,204,204);margin-bottom:0px;font-family:Verdana,sans-serif">
<tbody><tr class="" style="color:rgb(170,170,170)"><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<a href="http://rabbit1:15672/#/queues/%2F/federation%3A%20users%20-%3E%20rabbit%40rabbit3.c.rabbit-magic.internal" title="This is used internally by the federation mechanism." style="display:block;width:395px;color:rgb(170,170,170);font-weight:bold;text-decoration:none">federation: users -> rabbit@rabbit3.c.rabbit-magic.internal</a></td>
<td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<small style="font-size:0.8em">rabbit@</small>util1 <acronym title="Synchronised mirrors: rabbit@util2" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">+1</acronym></td>
<td class="" style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)));text-align:center!important">
</td><td class="" style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)));text-align:center!important">
<acronym title="x-expires: 3600000" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">Exp</acronym> <acronym title="durable: true" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">D</acronym> <acronym title="x-internal-purpose: federation" style="background-color:rgb(170,221,221);padding:2px 4px;border-top-left-radius:2px;border-top-right-radius:2px;border-bottom-right-radius:2px;border-bottom-left-radius:2px;border:none">Args</acronym></td>
</tr></tbody></table><br><b>For the slave:</b></div><div><b><br></b></div><div><b>Nothing.</b> Except on channels, where I find this: </div><div><br></div><table class="" style="border-collapse:collapse;border-width:1px;border-bottom-style:solid;border-bottom-color:rgb(204,204,204);margin-bottom:1em;font-family:Verdana,sans-serif">
<tbody><tr class=""><td style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)))">
<a href="http://162.222.179.163:15672/#/channels/%3Crabbit%40rabbit3.3.237.0%3E%20(1)" style="display:block;width:203px;color:black;font-weight:bold;text-decoration:none"><rabbit@rabbit3.3.237.0> (1)</a></td><td class="" style="font-size:12px;line-height:17px;font-family:Verdana,sans-serif;padding:4px;vertical-align:top;min-width:5em;width:auto;border-left-width:1px;border-left-style:solid;border-left-color:rgb(204,204,204);border-right-width:1px;border-right-style:solid;border-right-color:rgb(204,204,204);background-image:-webkit-gradient(linear,0% 0%,0% 100%,from(rgb(240,240,240)),to(rgb(224,224,224)));text-align:center!important">
federation<br><br></td></tr></tbody></table><div><br></div><div>Feel like we might be on to something?</div><div><br></div><div>How do I set this up?</div><div><br></div><div><br></div><div><br></div><div>As a side note: The queues and exchanges on the upstream might still be there since when we tried making it run both ways, not sure about this. We do however have the federation status on the SLAVE, and according to that it's up and running.<br>
<div><br></div></div></div><div class="gmail_extra"><br clear="all"><div><div dir="ltr">Best regards<br>Patrik Ring<br><br>Co-founder and CTO of Bloglovin.com<br><a href="mailto:patrik.ring@bloglovin.com" target="_blank">patrik.ring@bloglovin.com</a><br>
+46 730 59 78 14<div>+1 347 859 7999</div></div></div>
<br><br><div class="gmail_quote">On Tue, Mar 4, 2014 at 12:56 PM, Simon MacMullen <span dir="ltr"><<a href="mailto:simon@rabbitmq.com" target="_blank">simon@rabbitmq.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Hi Patrik.<br>
<br>
On 03/03/14 21:41, Patrik Ring wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Some messages come through (but are heavily delayed, as in hours) but<br>
they seem completely random.<br>
</blockquote>
<br>
That's definitely not right!<br>
<br>
First of all, could you send the output of "rabbitmqctl report" for each broker?<br>
<br>
Also, which version of RabbitMQ are you using?<br>
<br>
Secondly, you might want to investigate whether the underlying infrastructure used by federation is wired up correctly. There should be a queue for each (exchange, downstream) pairing declared in the upstream broker (called "federation: [exchange] -> [node]"). It should be bound (once) to an internal exchange with a similar name. That internal exchange should be bound to the upstream exchange with all the bindings that are in use downstream.<br>
<br>
Does it look like that is happening? Is the infrastructure queue seeing the message rates you would expect?<br>
<br>
Cheers, Simon<span class="HOEnZb"><font color="#888888"><br>
<br>
-- <br>
Simon MacMullen<br>
RabbitMQ, Pivotal<br>
</font></span></blockquote></div><br></div>