lib/ears/middlewares/max_retries.rb in ears-0.9.0 vs lib/ears/middlewares/max_retries.rb in ears-0.9.2
- old
+ new
@@ -21,12 +21,13 @@
private
attr_reader :retries, :error_queue
def handle_exceeded(payload)
- Bunny::Exchange
- .default(Ears.channel)
- .publish(payload, routing_key: error_queue)
+ Bunny::Exchange.default(Ears.channel).publish(
+ payload,
+ routing_key: error_queue,
+ )
:ack
end
def retries_exceeded?(metadata)
return false if metadata.headers.nil?