lib/connection/utils.rb in stomp-1.2.11 vs lib/connection/utils.rb in stomp-1.2.12
- old
+ new
@@ -179,10 +179,11 @@
:closed_check => true,
:hbser => false,
:stompconn => false,
:max_hbread_fails => 0,
:max_hbrlck_fails => 0,
+ :fast_hbs_adjust => 0.0,
}
res_params = default_params.merge(params)
if res_params[:dmh]
res_params = _expand_hosts(res_params)
@@ -227,9 +228,11 @@
# The receive may fail so we may need to retry.
while TRUE
begin
used_socket = socket()
return _receive(used_socket)
+ rescue Stomp::Error::MaxReconnectAttempts
+ raise
rescue
@failure = $!
raise unless @reliable
errstr = "receive failed: #{$!}"
if @logger && @logger.respond_to?(:on_miscerr)