<div dir="ltr">Hi jrob,<div><br></div><div>Curious to know whether you pushed this setup in production and how has it been? Any surprises? We are also testing this in perf lab and plan to push to production in couple of weeks.</div><div><br></div><div>Anup<br><br>On Wednesday, January 18, 2012 9:16:22 AM UTC-8, jrob wrote:<blockquote class="gmail_quote" style="margin: 0;margin-left: 0.8ex;border-left: 1px #ccc solid;padding-left: 1ex;">Yup, that was it exactly.  I just had the diff up, so here are the two major changes I had to make:<div><br></div><div><div><div>-    channel.queue( @queue, :durable => true ).subscribe(:ack=>true) do |header,message|</div><div>+    channel.queue( @queue, :durable => true, :arguments => {'x-ha-policy' => 'all'} ).subscribe(:ack=>true) do |header,message|</div></div></div><div><br></div><div><div>   def self.get_channel(host)</div><div>     connection = AMQP.connect( :host=>host )</div><div>+    connection.on_connection_<wbr>interruption do |conn, settings|</div><div>+      conn.reconnect(false,1)</div><div>+    end</div><div>+</div><div>     channel    = AMQP::Channel.new( connection )</div><div>+    channel.auto_recovery = true</div><div>+</div><div>+    channel</div><div>   end</div></div><div><br></div><div>As I said, this hasn't gone into production yet, but it seems to be doing well in our staging environment.  I don't think our message rate is high enough to really exercise this setup in staging, so I can't really comment on performance yet.  (We're holding off moving this into production as we are trying to provide high availability for our applications and services across the board, which in some cases means we will be using one VM for multiple services.  Since the other services aren't ready to go yet, we haven't pushed this up.)</div><div><br></div><div>- jrob</div><div><br></div></blockquote></div></div>