So I'm attempting a simple federation setup. I have one server distributing an exchange to two end point servers. Well it seems like it should be a simple set up but I must be missing something obvious. When I check the federation status I just see []...done. I've confirmed that I
can connect to both of the end points from the distribution server just
fine on 5672. There are no errors in the main or startup logs. If
anyone can point me in a direction for something to check or a mistake
in the config I would be greatly appreciative. <br><br>---- start of rabbitmq.config<br>[{rabbit,<br> [{rabbitmq_federation,<br> [ { exchanges, [<br> { exchange, "graphite" }, <br> { type, "topic" }, <br> { upstream_set, "gdisplay" }, <br> { durable, "true" } <br> ]},<br> { upstream_sets, [ <br> {"gdisplay",<br> [<br> [{ connection, "sansketch8display1" },<br> { exchange, "graphite" }] , <br> [{ connection, "sansketch8display2" },<br> { exchange, "graphite" }] ] <br> } ]}, <br> { connections, [ <br> {"sansketch8display1",<br> [<br> { prefetch_count, 1000 }, <br> { ha_policy, "all" }, <br> { expires, 3000 }, <br> { port, 5672 }, <br> { protocol, "amqp" }, <br> { virtual_host, "/" }, <br> { mechanism, default }, <br> { host, "sansketch8display1" }, <br> { reconnect_delay, 5 }, <br> { message_ttl, 10000 }, <br> { heartbeat, 1 }] <br> }, <br> {"sansketch8display2",<br> [<br> { prefetch_count, 1000 }, <br> { ha_policy, "all" }, <br> { expires, 3000 }, <br> { port, 5672 }, <br> { protocol, "amqp" }, <br> { virtual_host, "/" }, <br> { mechanism, default }, <br> { host, "sansketch8display2" }, <br> { reconnect_delay, 5 }, <br> { message_ttl, 10000 }, <br> { heartbeat, 1 }] <br> }<br> ]}<br>]}]<br>}<br>].<br>-------- End of config<br><br><br>---- Main log output:<br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>Limiting to approx 924 file handles (829 sockets)<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>Memory limit set to 803MB of 2009MB total.<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>Disk free limit set to 2009MB<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>Management plugin upgraded statistics to fine.<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>msg_store_transient: using rabbit_msg_store_ets_index to provide index<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>msg_store_persistent: using rabbit_msg_store_ets_index to provide index<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>started TCP Listener on [::]:5672<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>Management agent started.<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>Management plugin started. Port: 55672, path: /<br><br>=INFO REPORT==== 15-Aug-2012::10:42:10 ===<br>Statistics database started.<br><br>------ End main log<br><br>------ Start up log:<br>Activating RabbitMQ plugins ...<br>8 plugins activated:<br>* amqp_client-2.8.2<br>* mochiweb-1.3-rmq2.8.2-git<br>* rabbitmq_federation-2.8.2<br>* rabbitmq_federation_management-2.8.2<br>* rabbitmq_management-2.8.2<br>* rabbitmq_management_agent-2.8.2<br>* rabbitmq_mochiweb-2.8.2<br>* webmachine-1.7.0-rmq2.8.2-hg<br><br>** Found 0 name clashes in code paths <br><br>+---+ +---+<br>| | | |<br>| | | |<br>| | | |<br>| +---+ +-------+<br>| |<br>| RabbitMQ +---+ |<br>| | | |<br>| v2.8.2 +---+ |<br>| |<br>+-------------------+<br>AMQP 0-9-1 / 0-9 / 0-8<br>Copyright (C) 2007-2012 VMware, Inc.<br>Licensed under the MPL. See http://www.rabbitmq.com/<br><br>node : rabbit@sansketch8polling1<br>app descriptor : /usr/lib/rabbitmq/lib/rabbitmq_server-2.8.2/sbin/../ebin/rabbit.app<br>home dir : /home/rabbitmq<br>config file(s) : /etc/rabbitmq/rabbitmq.config<br>database dir : /var/lib/rabbitmq/mnesia/rabbit@sansketch8polling1<br>erlang version : 5.7.4<br><br>-- rabbit boot start<br>starting file handle cache server ...done<br>starting worker pool ...done<br>starting database ...done<br>starting database sync ...done<br>starting codec correctness check ...done<br>-- external infrastructure ready<br>starting statistics event manager ...done<br>starting logging server ...done<br>starting plugin registry ...done<br>starting auth mechanism amqplain ...done<br>starting auth mechanism cr-demo ...done<br>starting auth mechanism plain ...done<br>starting exchange type direct ...done<br>starting exchange type fanout ...done<br>starting exchange type headers ...done<br>starting exchange type topic ...done<br>-- kernel ready<br>starting node monitor ...done<br>starting cluster delegate ...done<br>starting guid generator ...done<br>starting alarm handler ...done<br>starting memory monitor ...done<br>-- core initialized<br>starting federation ...done<br>starting federation exchange type ...done<br>starting federation upstream exchange type ...done<br>starting management agent ...done<br>starting exchange, queue and binding recovery ...done<br>starting configured definitions ...done<br>starting empty DB check ...done<br>starting mirror queue slave sup ...done<br>starting adding mirrors to queues ...done<br>-- message delivery logic ready<br>starting error log relay ...done<br>starting networking ...done<br>starting notify cluster nodes ...done<br>starting direct client ...done<br><br>broker running<br>--- End main log<br><br>