lib/qsagi/queue.rb in qsagi-0.2.0 vs lib/qsagi/queue.rb in qsagi-0.2.1

@@ -39,10 +39,13 @@
           :queue_arguments => {"x-ha-policy" => "all"},
           :persistent => true,
           :mandatory => true,
           :serializer => _serializer,
           :exchange_options => _exchange_options,
-          :exchange => _exchange
+          :exchange => _exchange,
+          :connect_timeout => 5,
+          :read_timeout => 5,
+          :write_timeout => 5
         }
       end
 
       def exchange(exchange, options = {})
         @exchange = exchange