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