lib/bunny/session.rb in bunny-2.8.1 vs lib/bunny/session.rb in bunny-2.9.0
- old
+ new
@@ -462,11 +462,11 @@
# Parses an amqp[s] URI into a hash that {Bunny::Session#initialize} accepts.
#
# @param [String] uri amqp or amqps URI to parse
# @return [Hash] Parsed URI as a hash
def self.parse_uri(uri)
- AMQ::Settings.parse_amqp_url(uri)
+ AMQ::Settings.configure(uri)
end
# Checks if a queue with given name exists.
#
# Implemented using queue.declare
@@ -740,10 +740,10 @@
recover_channels
end
rescue HostListDepleted
reset_address_index
retry
- rescue TCPConnectionFailedForAllHosts, TCPConnectionFailed, AMQ::Protocol::EmptyResponseError, SystemCallError => e
+ rescue TCPConnectionFailedForAllHosts, TCPConnectionFailed, AMQ::Protocol::EmptyResponseError, SystemCallError, Timeout::Error => e
@logger.warn "TCP connection failed, reconnecting in #{@network_recovery_interval} seconds"
if should_retry_recovery?
decrement_recovery_attemp_counter!
if recoverable_network_failure?(e)
announce_network_failure_recovery